prometheus

Documentation

Index

• type ConsumerMetrics
  • func NewConsumerMetrics(lc fx.Lifecycle, version version.Version) *ConsumerMetrics
  • func (m *ConsumerMetrics) Collect(ch chan<- prometheus.Metric)
  • func (m *ConsumerMetrics) Describe(ch chan<- *prometheus.Desc)
  • func (m *ConsumerMetrics) Handler(topic, channel string, h handler.Handler) handler.Handler
• type ProducerMetrics
  • func NewProducerMetrics(lc fx.Lifecycle, version version.Version) *ProducerMetrics
  • func (m *ProducerMetrics) Collect(ch chan<- prometheus.Metric)
  • func (m *ProducerMetrics) Describe(ch chan<- *prometheus.Desc)
  • func (m *ProducerMetrics) Producer(p producer.Producer) producer.Producer

Types

type ConsumerMetrics

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

ConsumerMetrics for prometheus.

func NewConsumerMetrics

func NewConsumerMetrics(lc fx.Lifecycle, version version.Version) *ConsumerMetrics

NewConsumerMetrics for prometheus.

func (*ConsumerMetrics) Collect

func (m *ConsumerMetrics) Collect(ch chan<- prometheus.Metric)

Collect is called by the Prometheus registry when collecting metrics. The implementation sends each collected metric via the provided channel and returns once the last metric has been sent.

func (*ConsumerMetrics) Describe

func (m *ConsumerMetrics) Describe(ch chan<- *prometheus.Desc)

Describe sends the super-set of all possible descriptors of metrics collected by this Collector to the provided channel and returns once the last descriptor has been sent.

func (*ConsumerMetrics) Handler

func (m *ConsumerMetrics) Handler(topic, channel string, h handler.Handler) handler.Handler

ServerHandler for prometheus.

type ProducerMetrics

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

ProducerMetrics for prometheus.

func NewProducerMetrics

func NewProducerMetrics(lc fx.Lifecycle, version version.Version) *ProducerMetrics

NewProducerMetrics for prometheus.

func (*ProducerMetrics) Collect

func (m *ProducerMetrics) Collect(ch chan<- prometheus.Metric)

Collect is called by the Prometheus registry when collecting metrics. The implementation sends each collected metric via the provided channel and returns once the last metric has been sent.

func (*ProducerMetrics) Describe

func (m *ProducerMetrics) Describe(ch chan<- *prometheus.Desc)

Describe sends the super-set of all possible descriptors of metrics collected by this Collector to the provided channel and returns once the last descriptor has been sent.

func (*ProducerMetrics) Producer

func (m *ProducerMetrics) Producer(p producer.Producer) producer.Producer

Producer for prometheus.