otel

Documentation

Index

• func Extract(ctx context.Context, message *azservicebus.ReceivedMessage) context.Context
• func Inject(ctx context.Context, msg *azservicebus.Message)
• func MessageAttributes(message *azservicebus.ReceivedMessage) []attribute.KeyValue
• func MessageCarrierAdapter(message *azservicebus.Message) propagation.TextMapCarrier
• func ReceivedMessageCarrierAdapter(message *azservicebus.ReceivedMessage) propagation.TextMapCarrier

Functions

func Extract

func Extract(ctx context.Context, message *azservicebus.ReceivedMessage) context.Context

Extract extracts the remote trace context from the message if exists, and set it onto ctx

func Inject

func Inject(ctx context.Context, msg *azservicebus.Message)

func MessageAttributes

func MessageAttributes(message *azservicebus.ReceivedMessage) []attribute.KeyValue

func MessageCarrierAdapter

func MessageCarrierAdapter(message *azservicebus.Message) propagation.TextMapCarrier

MessageCarrierAdapter wraps a azservicebus.Message so that it implements the propagation.TextMapCarrier interface

func ReceivedMessageCarrierAdapter

func ReceivedMessageCarrierAdapter(message *azservicebus.ReceivedMessage) propagation.TextMapCarrier

ReceivedMessageCarrierAdapter wraps a servicebus ReceivedMessage so that it implements the TextMapCarrier interface