octrace

Documentation

Overview

Package octrace is the logic for receiving OpenCensus trace protobuf defined spans from already instrumented applications and then passing them onto a TracesReceiverSink instance.

Index

• type Receiver
  • func New(nextConsumer consumer.Traces, set receiver.Settings) (*Receiver, error)
  • func (ocr *Receiver) Config(agenttracepb.TraceService_ConfigServer) error
  • func (ocr *Receiver) Export(tes agenttracepb.TraceService_ExportServer) error

Types

type Receiver

type Receiver struct {
	agenttracepb.UnimplementedTraceServiceServer
	// contains filtered or unexported fields
}

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

func New

func New(nextConsumer consumer.Traces, set receiver.Settings) (*Receiver, error)

New creates a new opencensus.Receiver reference.

func (*Receiver) Config

func (ocr *Receiver) Config(agenttracepb.TraceService_ConfigServer) error

Config handles configuration messages.

func (*Receiver) Export

func (ocr *Receiver) Export(tes agenttracepb.TraceService_ExportServer) error

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