package
3.0.0+incompatible
Repository: https://github.com/sciclon2/kafka-lag-go.git
Documentation: pkg.go.dev
# Functions
MergeLabels merges the base labels with extra labels.
NewLagProcessor creates a new instance of LagProcessor.
NewLocalPrometheusMetrics creates a new PrometheusMetrics instance with the provided extra labels.
# Structs
LagProcessor processes and records lag metrics for Kafka consumer groups.
PrometheusMetrics holds the Prometheus metrics to be exposed.