ocmetrics

Documentation

Overview

Package ocmetrics is the logic for receiving OpenCensus metrics proto from already instrumented applications and then passing them onto a metricsink instance.

Index

• type Receiver
  • func New(id config.ComponentID, nextConsumer consumer.Metrics, ...) (*Receiver, error)
  • func (ocr *Receiver) Export(mes agentmetricspb.MetricsService_ExportServer) error

Types

type Receiver

type Receiver struct {
	agentmetricspb.UnimplementedMetricsServiceServer
	// contains filtered or unexported fields
}

Receiver is the type used to handle metrics from OpenCensus exporters.

func New

func New(id config.ComponentID, nextConsumer consumer.Metrics, set component.ReceiverCreateSettings) (*Receiver, error)

New creates a new ocmetrics.Receiver reference.

func (*Receiver) Export

func (ocr *Receiver) Export(mes agentmetricspb.MetricsService_ExportServer) error

Export is the gRPC method that receives streamed metrics from OpenCensus-metricproto compatible libraries/applications.