opentracing

Documentation

Index

• Variables
• func InjectSpan(span opentracing.Span, m *sqs.Message) error
• func SpanFromMessage(spanName string, m *sqs.Message) opentracing.Span
• type Middleware
  • func (m *Middleware) HandleMessage(msg *mq.Message) error
• type SQSMessageAttributeCarrier
  • func (c SQSMessageAttributeCarrier) ForeachKey(handler func(key, val string) error) error
  • func (c SQSMessageAttributeCarrier) Set(key, val string)

Variables

var DefaultSpanName = "sqs.message"

var DefaultTagger = func(span opentracing.Span, m *mq.Message, err error) {
	if err != nil {
		span.SetTag("error.error", err)
	}
}

Functions

func InjectSpan

func InjectSpan(span opentracing.Span, m *sqs.Message) error

func SpanFromMessage

func SpanFromMessage(spanName string, m *sqs.Message) opentracing.Span

Types

type Middleware

type Middleware struct {
	Handler  mq.Handler
	SpanName string
	Tagger   func(opentracing.Span, *mq.Message, error)
}

func (*Middleware) HandleMessage

func (m *Middleware) HandleMessage(msg *mq.Message) error

type SQSMessageAttributeCarrier

type SQSMessageAttributeCarrier map[string]*sqs.MessageAttributeValue

func (SQSMessageAttributeCarrier) ForeachKey

func (c SQSMessageAttributeCarrier) ForeachKey(handler func(key, val string) error) error

func (SQSMessageAttributeCarrier) Set

func (c SQSMessageAttributeCarrier) Set(key, val string)