metrics

Documentation

Overview

Package metrics creates envoy grpc metricsserver. It will collect metrics, convert them from prometheus to OTLP. It will then push the OTLP metric onto the next component in an OTLP pipeline.

Index

• type Receiver
  • func New(nextConsumer consumer.Metrics, logger *zap.Logger) *Receiver
  • func (r *Receiver) Register(g *grpc.Server)
  • func (r *Receiver) StreamMetrics(stream metricsv3.MetricsService_StreamMetricsServer) error

Types

type Receiver

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

Receiver is the metrics implementation for an envoy metrics receiver.

func New

func New(nextConsumer consumer.Metrics, logger *zap.Logger) *Receiver

New creates a new Receiver reference.

func (*Receiver) Register

func (r *Receiver) Register(g *grpc.Server)

Register will register the MetricsServiceServer on the provided grpc Server.

func (*Receiver) StreamMetrics

func (r *Receiver) StreamMetrics(stream metricsv3.MetricsService_StreamMetricsServer) error

StreamMetrics implements the envoy MetricsServiceServer method StreamMetrics. It will consume the envoy prometheus metrics and write them to the nextConsumer.