Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewContextFromConsumerMessage ¶
func NewContextFromConsumerMessage(ctx context.Context, message *sarama.ConsumerMessage) context.Context
NewContextFromConsumerMessage returns a context with an initialized SpanContext, where the TraceID and the SpanID are retrieved from the the consumer message headers.
func NewProducerMessage ¶
func NewProducerMessage(ctx context.Context) *sarama.ProducerMessage
NewProducerMessage retrieves the TraceID and SpanID from the provided context and if they're both valid it'll return a *sarama.ProducerMessage with pre-populated telemetry headers, otherwise it'll return an empty initialized *sarama.ProducerMessage.
func TraceAndSpanFromHeaders ¶
func TraceAndSpanFromHeaders( headers ...*sarama.RecordHeader, ) (traceID trace.TraceID, spanID trace.SpanID, err error)
TraceAndSpanFromHeaders iterates through the headers and if one of the headers matches the expected TraceID and SpanID keys, it'll attempt to parse it's hex values.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.