mq

Documentation

Index

• Variables
• func ExtractSpanLink(ctx context.Context, d amqp.Delivery) context.Context
• func InjectTracing(ctx context.Context, m *amqp.Publishing) error
• func NewChannel() (ch *amqp.Channel)
• func NewFailableChannel() (*amqp.Channel, error)

Variables

var (
	Connection *amqp.Connection
)

Functions

func ExtractSpanLink

func ExtractSpanLink(ctx context.Context, d amqp.Delivery) context.Context

extracts trace context from amqp delivery headers

func InjectTracing

func InjectTracing(ctx context.Context, m *amqp.Publishing) error

injects trace context into amqp headers

func NewChannel

func NewChannel() (ch *amqp.Channel)

We may want a failure tolerant version of new channel in some cases.

func NewFailableChannel

func NewFailableChannel() (*amqp.Channel, error)

A failure tolerant new channel