Documentation
¶
Overview ¶
Package receiver is the logic that receives exported TraceData from OC Agents on each test server.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TestCoordinatorSink ¶
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.
Source Files
Click to show internal directories.
Click to hide internal directories.