Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PartitionInfoCollector ¶
type PartitionInfoCollector struct {
// contains filtered or unexported fields
}
PartitionInfoCollector is a Kafka prometheus.Collector. It uses a exporter.ConsumerGroupInfoClient for the actual querying of Kafka.
To speed up collection each consumer group is collected concurrently.
func NewPartitionInfoCollector ¶
func NewPartitionInfoCollector(ctx context.Context, client exporter.ConsumerGroupInfoClient, execTimeout time.Duration, maxConcurrentQueries int) *PartitionInfoCollector
NewPartitionInfoCollector returns a prometheus.Collector that queries Kafka using client. concurrency sets an upper limit on the number concurrent Kafka concumer group queries running.
func (*PartitionInfoCollector) Collect ¶
func (p *PartitionInfoCollector) Collect(c chan<- prometheus.Metric)
Collect triggers an on-demand scraping from Kafka and transmits metrics into c.
func (*PartitionInfoCollector) Describe ¶
func (p *PartitionInfoCollector) Describe(c chan<- *prometheus.Desc)
Describe transmits all metric descriptions to c.
Source Files
Click to show internal directories.
Click to hide internal directories.