kafkaprometheus

Jul 25, 2023

Changes in this version

+ const SlugSeparator

+ func SplitSlug(s string) (topic, eventName, groupID string)

+ type KafkaStatCollector interface

+ GetReaderStats func() ([]kafka.ReaderStats, []string)

+ GetWriterStats func() ([]kafka.WriterStats, []string)

+ type ReaderCollector struct

+ Client KafkaStatCollector

+ func (r *ReaderCollector) Collect(metrics chan<- prometheus.Metric)

+ func (r *ReaderCollector) Describe(c chan<- *prometheus.Desc)

+ type WriterCollector struct

+ Client KafkaStatCollector

+ func (w *WriterCollector) Collect(metrics chan<- prometheus.Metric)

+ func (w *WriterCollector) Describe(c chan<- *prometheus.Desc)