prometheus

Documentation

Index

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

Types

type ConsumerCollector

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

ConsumerCollector for prometheus.

func NewConsumerCollector

func NewConsumerCollector(lc fx.Lifecycle, version version.Version) *ConsumerCollector

NewConsumerCollector for prometheus.

func (*ConsumerCollector) Collect

func (m *ConsumerCollector) 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 (*ConsumerCollector) Describe

func (m *ConsumerCollector) 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 (*ConsumerCollector) Handler

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

ServerHandler for prometheus.

type ProducerCollector

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

ProducerCollector for prometheus.

func NewProducerCollector

func NewProducerCollector(lc fx.Lifecycle, version version.Version) *ProducerCollector

NewProducerCollector for prometheus.

func (*ProducerCollector) Collect

func (m *ProducerCollector) 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 (*ProducerCollector) Describe

func (m *ProducerCollector) 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 (*ProducerCollector) Producer

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

Producer for prometheus.