Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterGoBuildInfo()
- type BrokerIncrementObserver
- type BrokerMetrics
- type CacheIncrementer
- type CacheMetrics
- type DBIncrementObserver
- type DBMetrics
- func (m *DBMetrics) IncDatabaseDeletes(db, operation, result string)
- func (m *DBMetrics) IncDatabaseInserts(db, operation, result string)
- func (m *DBMetrics) IncDatabaseSelects(db, operation, result string)
- func (m *DBMetrics) IncDatabaseUpdates(db, operation, result string)
- func (m *DBMetrics) NewDatabaseDeleteTimer(db, operation string) *prometheus.Timer
- func (m *DBMetrics) NewDatabaseInsertTimer(db, operation string) *prometheus.Timer
- func (m *DBMetrics) NewDatabaseSelectTimer(db, operation string) *prometheus.Timer
- func (m *DBMetrics) NewDatabaseUpdateTimer(db, operation string) *prometheus.Timer
- type HTTPIncrementObserver
- type HTTPMetrics
- type ProcessingIncrementObserver
- type ProcessingMetrics
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 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 (*DBMetrics) IncDatabaseInserts ¶
func (*DBMetrics) IncDatabaseSelects ¶
func (*DBMetrics) IncDatabaseUpdates ¶
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 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
Click to show internal directories.
Click to hide internal directories.