promcommon

package module
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 1, 2023 License: MIT Imports: 2 Imported by: 2

README

promcommon

Prometheus metrics that are common for all services

Documentation

Index

Constants

View Source
const (
	Attempt = "attempt"
	Failure = "failure"

	PostgreSQL = "postgresql"
	MySQL      = "mysql"
	Clickhouse = "clickhouse"
	Mongo      = "mongo"
	Aerospike  = "aerospike"
)

Variables

View Source
var CustomBuckets = []float64{.005, .01, .025, 0.05, .1, .25, .5, 1, 2, 5, 10,
	20, 30, 40, 50, 60, 90, 120, 300,
}

CustomBuckets extends Prometheus built-in DefBuckets for long operations like 30s queries

Functions

func RegisterGoBuildInfo

func RegisterGoBuildInfo()

Types

type BrokerIncrementObserver

type BrokerIncrementObserver interface {
	IncBrokerMessagesReads(queue, result string)
	IncBrokerMessagesWrites(queue, result string)
	NewBrokerWriteTimer(queue string) *prometheus.Timer
}

type BrokerMetrics

type BrokerMetrics struct {
	// contains filtered or unexported fields
}

func NewBrokerMetrics

func NewBrokerMetrics() *BrokerMetrics

func (*BrokerMetrics) IncBrokerMessagesReads

func (m *BrokerMetrics) IncBrokerMessagesReads(queue, result string)

func (*BrokerMetrics) IncBrokerMessagesWrites

func (m *BrokerMetrics) IncBrokerMessagesWrites(queue, result string)

func (*BrokerMetrics) NewBrokerWriteTimer

func (m *BrokerMetrics) NewBrokerWriteTimer(queue string) *prometheus.Timer

type CacheIncrementer

type CacheIncrementer interface {
	IncHits(operation string)
	IncMisses(operation string)
}

type CacheMetrics

type CacheMetrics struct {
	// contains filtered or unexported fields
}

func NewCacheMetrics

func NewCacheMetrics() *CacheMetrics

func (*CacheMetrics) IncHits

func (m *CacheMetrics) IncHits(operation string)

func (*CacheMetrics) IncMisses

func (m *CacheMetrics) IncMisses(operation string)

type DBIncrementObserver

type DBIncrementObserver interface {
	IncDatabaseSelects(db, operation, result string)
	IncDatabaseInserts(db, operation, result string)
	IncDatabaseUpdates(db, operation, result string)
	IncDatabaseDeletes(db, operation, result string)
	NewDatabaseSelectTimer(db, operation string) *prometheus.Timer
	NewDatabaseInsertTimer(db, operation string) *prometheus.Timer
	NewDatabaseUpdateTimer(db, operation string) *prometheus.Timer
	NewDatabaseDeleteTimer(db, operation string) *prometheus.Timer
}

type DBMetrics

type DBMetrics struct {
	// contains filtered or unexported fields
}

func NewDBMetrics

func NewDBMetrics() *DBMetrics

func (*DBMetrics) IncDatabaseDeletes

func (m *DBMetrics) IncDatabaseDeletes(db, operation, result string)

func (*DBMetrics) IncDatabaseInserts

func (m *DBMetrics) IncDatabaseInserts(db, operation, result string)

func (*DBMetrics) IncDatabaseSelects

func (m *DBMetrics) IncDatabaseSelects(db, operation, result string)

func (*DBMetrics) IncDatabaseUpdates

func (m *DBMetrics) IncDatabaseUpdates(db, operation, result string)

func (*DBMetrics) NewDatabaseDeleteTimer

func (m *DBMetrics) NewDatabaseDeleteTimer(db, operation string) *prometheus.Timer

func (*DBMetrics) NewDatabaseInsertTimer

func (m *DBMetrics) NewDatabaseInsertTimer(db, operation string) *prometheus.Timer

func (*DBMetrics) NewDatabaseSelectTimer

func (m *DBMetrics) NewDatabaseSelectTimer(db, operation string) *prometheus.Timer

func (*DBMetrics) NewDatabaseUpdateTimer

func (m *DBMetrics) NewDatabaseUpdateTimer(db, operation string) *prometheus.Timer

type HTTPIncrementObserver

type HTTPIncrementObserver interface {
	IncOutgoingHTTPRequests(destination, endpoint, result string)
	NewOutgoingHTTPRequestTimer(destination, endpoint string) *prometheus.Timer
}

type HTTPMetrics

type HTTPMetrics struct {
	// contains filtered or unexported fields
}

func NewHTTPMetrics

func NewHTTPMetrics() *HTTPMetrics

func (*HTTPMetrics) IncOutgoingHTTPRequests

func (m *HTTPMetrics) IncOutgoingHTTPRequests(destination, endpoint, result string)

func (*HTTPMetrics) NewOutgoingHTTPRequestTimer

func (m *HTTPMetrics) NewOutgoingHTTPRequestTimer(destination, endpoint string) *prometheus.Timer

type ProcessingIncrementObserver

type ProcessingIncrementObserver interface {
	IncEntitiesProcessed(entityType, result string)
	NewEntityProcessingTimer(entityType string) *prometheus.Timer
	IncInFlight(operationName string)
	DecInFlight(operationName string)
}

type ProcessingMetrics

type ProcessingMetrics struct {
	// contains filtered or unexported fields
}

func NewProcessingMetrics

func NewProcessingMetrics() *ProcessingMetrics

func (*ProcessingMetrics) DecInFlight

func (m *ProcessingMetrics) DecInFlight(operationName string)

func (*ProcessingMetrics) IncEntitiesProcessed

func (m *ProcessingMetrics) IncEntitiesProcessed(entityType, result string)

func (*ProcessingMetrics) IncInFlight

func (m *ProcessingMetrics) IncInFlight(operationName string)

func (*ProcessingMetrics) NewEntityProcessingTimer

func (m *ProcessingMetrics) NewEntityProcessingTimer(entityType string) *prometheus.Timer

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳