prometheus

Documentation

Index

• type KafkaMetricsHook
  • func NewKafkaMetricsHook(opts prometheus.SummaryOpts) *KafkaMetricsHook
  • func (h *KafkaMetricsHook) WrapProducer(producer sarama.SyncProducer) sarama.SyncProducer

Types

type KafkaMetricsHook

type KafkaMetricsHook struct {
	// contains filtered or unexported fields
}

func NewKafkaMetricsHook

func NewKafkaMetricsHook(opts prometheus.SummaryOpts) *KafkaMetricsHook

NewKafkaMetricsHook 初始化 KafkaMetricsHook 实例，并注册 Prometheus 指标

func (*KafkaMetricsHook) WrapProducer

func (h *KafkaMetricsHook) WrapProducer(producer sarama.SyncProducer) sarama.SyncProducer

WrapProducer 为 Sarama 同步生产者包装一个带有指标记录的生产者