metrics

Documentation

Index

• Constants
• Variables
• func ObserveAivenLatency(operation, pool string, fun func() error) error
• func Register(registry prometheus.Registerer)

Constants

const (
	Namespace = "kafkarator"

	LabelAivenOperation = "operation"
	LabelApp            = "app"
	LabelGroupID        = "group_id"
	LabelPool           = "pool"
	LabelSource         = "source"
	LabelStatus         = "status"
	LabelSyncState      = "synchronization_state"
	LabelTeam           = "team"
	LabelTopic          = "topic"

	// Metadata labels
	LabelVersion = "version"
	LabelPlan    = "plan"

	SourceCluster = "cluster"
	SourceAiven   = "aiven"
)

Variables

var (
	Topics = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name:      "topics",
		Namespace: Namespace,
		Help:      "number of topics",
	}, []string{LabelSource, LabelTeam, LabelPool})

	TopicsProcessed = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name:      "topics_processed",
		Namespace: Namespace,
		Help:      "number of topics synchronized with aiven",
	}, []string{LabelSyncState, LabelPool})

	StreamsProcessed = prometheus.NewCounterVec(prometheus.CounterOpts{
		Name:      "streams_processed",
		Namespace: Namespace,
		Help:      "number of streams synchronized with aiven",
	}, []string{LabelSyncState, LabelPool})

	Acls = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name:      "acls",
		Namespace: Namespace,
		Help:      "number of acls",
	}, []string{LabelTopic, LabelPool, LabelSource})

	AivenLatency = prometheus.NewHistogramVec(prometheus.HistogramOpts{
		Name:      "aiven_latency",
		Namespace: Namespace,
		Help:      "latency in aiven api operations",
		Buckets:   []float64{.005, .010, .015, .020, .025, .030, .035, .040, .045, .050, .1, .2, .3, .4, .5, 1, 2, 3, 4, 5, 10, 15, 20},
	}, []string{LabelAivenOperation, LabelStatus, LabelPool})

	SecretQueueSize = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name:      "secret_queue_size",
		Namespace: Namespace,
		Help:      "unwritten secrets for a specific group id",
	}, []string{LabelGroupID})

	PoolNodes = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name:      "kafka_pool_nodes_count",
		Namespace: Namespace,
		Help:      "number of nodes in the kafka pool",
	}, []string{LabelPool})

	PoolInfo = prometheus.NewGaugeVec(prometheus.GaugeOpts{
		Name:      "kafka_pool_info",
		Namespace: Namespace,
		Help:      "metadata about kafka pool",
	}, []string{LabelPool, LabelVersion, LabelPlan})
)

Functions

func ObserveAivenLatency

func ObserveAivenLatency(operation, pool string, fun func() error) error

func Register

func Register(registry prometheus.Registerer)