otelamqp

Documentation

Index

• type MessageCarrier
  • func NewMessageCarrier(msg *message.Message) *MessageCarrier
  • func (c *MessageCarrier) Get(key string) string
  • func (c *MessageCarrier) Keys() []string
  • func (c *MessageCarrier) Set(key, val string)
• type PubSub
  • func New(p pubSub) *PubSub
  • func (p *PubSub) Publish(queue string, messages ...*message.Message) error
  • func (p *PubSub) PublishWithOpts(queue string, msg *message.Message, opts ...spi.Option) error
  • func (p *PubSub) Subscribe(ctx context.Context, queue string) (<-chan *message.Message, error)
  • func (p *PubSub) SubscribeWithOpts(ctx context.Context, queue string, opts ...spi.Option) (<-chan *message.Message, error)

Types

type MessageCarrier

type MessageCarrier struct {
	// contains filtered or unexported fields
}

MessageCarrier injects and extracts traces from a Message.

func NewMessageCarrier

func NewMessageCarrier(msg *message.Message) *MessageCarrier

NewMessageCarrier creates a new MessageCarrier.

func (*MessageCarrier) Get

func (c *MessageCarrier) Get(key string) string

Get retrieves a single value for a given key.

func (*MessageCarrier) Keys

func (c *MessageCarrier) Keys() []string

Keys returns a slice of all key identifiers in the carrier.

func (*MessageCarrier) Set

func (c *MessageCarrier) Set(key, val string)

Set sets a header.

type PubSub

type PubSub struct {
	// contains filtered or unexported fields
}

PubSub wraps the publisher/subscriber to inject/collect OpenTelemetry tracing data.

func New

func New(p pubSub) *PubSub

New returns an OpenTelemetry publisher/subscriber wrapper.

func (*PubSub) Publish

func (p *PubSub) Publish(queue string, messages ...*message.Message) error

Publish injects OpenTelemetry tracing data before publishing the given messages.

func (*PubSub) PublishWithOpts

func (p *PubSub) PublishWithOpts(queue string, msg *message.Message, opts ...spi.Option) error

PublishWithOpts injects OpenTelemetry tracing data before publishing the given message.

func (*PubSub) Subscribe

func (p *PubSub) Subscribe(ctx context.Context, queue string) (<-chan *message.Message, error)

Subscribe subscribes to the given queue. When messages are consumed, OpenTelemetry data is extracted from the message header.

func (*PubSub) SubscribeWithOpts

func (p *PubSub) SubscribeWithOpts(ctx context.Context, queue string, opts ...spi.Option) (<-chan *message.Message, error)

SubscribeWithOpts subscribes to the given queue. When messages are consumed, OpenTelemetry data is extracted from the message header.