kafkaprometheus

Documentation

Index

• Constants
• func SplitSlug(s string) (topic, eventName, groupID string)
• type KafkaStatCollector
• type ReaderCollector
  • func (r *ReaderCollector) Collect(metrics chan<- prometheus.Metric)
  • func (r *ReaderCollector) Describe(c chan<- *prometheus.Desc)
• type WriterCollector
  • func (w *WriterCollector) Collect(metrics chan<- prometheus.Metric)
  • func (w *WriterCollector) Describe(c chan<- *prometheus.Desc)

Constants

const SlugSeparator = "$" // SlugSeparator is excluded by topicRegex.

Functions

func SplitSlug

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

ParseSlug returns topic, eventName, and groupID

Types

type KafkaStatCollector

type KafkaStatCollector interface {
	GetWriterStats() ([]kafka.WriterStats, []string)
	GetReaderStats() ([]kafka.ReaderStats, []string)
}

type ReaderCollector

type ReaderCollector struct {
	Client KafkaStatCollector
}

ReaderCollector implements prometheus' Collector interface, for kafka reader.

func (*ReaderCollector) Collect

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

func (*ReaderCollector) Describe

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

type WriterCollector

type WriterCollector struct {
	Client KafkaStatCollector
}

WriterCollector implements prometheus' Collector interface, for kafka writer.

func (*WriterCollector) Collect

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

func (*WriterCollector) Describe

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