rabbitmq

package

v1.5.1 Latest Latest Go to latest Published: Mar 20, 2026 License: MIT Imports: 2 Imported by: 0

Details

Package rabbitmq provides helpers for configuring RabbitMQ clients with OpenTelemetry tracing (for both producers and consumers).

This section is empty.

This section is empty.

func ExtractAMQPHeaders(ctx context.Context, headers map[string]interface{}) context.Context

ExtractAMQPHeaders extracts the tracing from the header and puts it into the context

Returns a new context with the tracing information from the headers

func InjectAMQPHeaders(ctx context.Context) map[string]interface{}

InjectAMQPHeaders injects the tracing from the context into the header map

type AmqpHeadersCarrier map[string]interface{}

AmqpHeadersCarrier is a map of headers that implements the TextMapCarrier interface

func (a AmqpHeadersCarrier) Get(key string) string

Get returns the value for the key

func (a AmqpHeadersCarrier) Keys() []string

Keys returns the keys of the carrier

func (a AmqpHeadersCarrier) Set(key string, value string)

Set sets the value for the key