metrics

package
v0.9.4 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2025 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TopicLabel = "topic"
	ErrorLabel = "error"
)

Labels

View Source
const (
	MessagesReceived = BasePath + "messages_received_total"
	MessagesDropped  = BasePath + "messages_dropped_total"
	FlushCount       = BasePath + "flushes_total"
)

Counters

View Source
const (
	ConnectionStatus = BasePath + "connection_status"
	BufferSize       = BasePath + "buffer_messages"
	LastFlushTime    = BasePath + "last_flush_timestamp"
)

Gauges

View Source
const BasePath = "batcher_"

Variables

This section is empty.

Functions

func InitMetricsProvider

func InitMetricsProvider()

Types

type Provider

type Provider struct {
	// contains filtered or unexported fields
}
var (
	Local Provider
)

func (Provider) Counter

func (p Provider) Counter(name string) *prometheus.CounterVec

func (Provider) Gauge

func (p Provider) Gauge(name string) *prometheus.GaugeVec

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL