receiver

Documentation

Overview

Package receiver is the logic that receives exported TraceData from OC Agents on each test server.

Index

• type TestCoordinatorSink
  • func NewOCTraceReceiver(addr string) (*opencensus.Receiver, *TestCoordinatorSink, error)
  • func (tcs TestCoordinatorSink) ReceiveTraceData(ctx context.Context, td data.TraceData) (*receiver.TraceReceiverAcknowledgement, error)

Types

type TestCoordinatorSink

type TestCoordinatorSink struct {
	SpansPerNode map[*commonpb.Node][]*tracepb.Span
}

TestCoordinatorSink is a struct that implements receiver.TraceReceiverSink. It can accept TraceData as well as expose stored TraceData for validation.

func NewOCTraceReceiver

func NewOCTraceReceiver(addr string) (*opencensus.Receiver, *TestCoordinatorSink, error)

NewOCTraceReceiver creates a new OpenCensus Receiver at the given address. Also binds TraceServiceGrpc to the created gRPC server and starts Trace reception.

func (TestCoordinatorSink) ReceiveTraceData

func (tcs TestCoordinatorSink) ReceiveTraceData(ctx context.Context, td data.TraceData) (*receiver.TraceReceiverAcknowledgement, error)

ReceiveTraceData receives the span data in the protobuf format, groups them by Node and stores them.