middleware

Documentation

Index

• func ContextFromMessageAttributes(tracer trace.Tracer, spanName string) func(next sqsprocessor.ProcessFunc) sqsprocessor.ProcessFunc
• func ContextFromMessageBody[T propagation.TextMapCarrier](tracer trace.Tracer, spanName string) func(next CustomProcessFunc[T]) CustomProcessFunc[T]
• func JSONDecode[T any](processFunc CustomProcessFunc[T]) sqsprocessor.ProcessFunc
• func RawMessage(processFunc CustomProcessFunc[string]) sqsprocessor.ProcessFunc
• func XMLDecode[T any](processFunc CustomProcessFunc[T]) sqsprocessor.ProcessFunc
• type CustomProcessFunc
• type Decoder
• type MessageAttributeValueCarrier
  • func NewMessageAttributeValueCarrier(init map[string]types.MessageAttributeValue) *MessageAttributeValueCarrier
  • func (m *MessageAttributeValueCarrier) Get(key string) string
  • func (m *MessageAttributeValueCarrier) Keys() (keys []string)
  • func (m *MessageAttributeValueCarrier) Set(key string, value string)

Functions

func ContextFromMessageAttributes

func ContextFromMessageAttributes(tracer trace.Tracer, spanName string) func(next sqsprocessor.ProcessFunc) sqsprocessor.ProcessFunc

ContextFromMessageAttributes assumes the MessageAttributeValueCarrier was used alongside a propagation.TraceContext to inject a trace from the sender

func ContextFromMessageBody

func ContextFromMessageBody[T propagation.TextMapCarrier](tracer trace.Tracer, spanName string) func(next CustomProcessFunc[T]) CustomProcessFunc[T]

ContextFromMessageBody requires that the concrete message type implements the open telemetry propagation.TextMapCarrier interface, such as embedding the propagation.MapCarrier type: e.g.

type Message struct {
	AField string `json:"a_field"`
	propagation.MapCarrier `json:"trace"`
}

func JSONDecode

func JSONDecode[T any](processFunc CustomProcessFunc[T]) sqsprocessor.ProcessFunc

JSONDecode decodes the sqs message body into a given struct with json encoding

func RawMessage

func RawMessage(processFunc CustomProcessFunc[string]) sqsprocessor.ProcessFunc

RawMessage simply extracts the string value of an sqs message and passes it to a given CustomProcessFunc

func XMLDecode

func XMLDecode[T any](processFunc CustomProcessFunc[T]) sqsprocessor.ProcessFunc

XMLDecode decodes the sqs message into a given struct with xml encoding

Types

type CustomProcessFunc

type CustomProcessFunc[T any] func(context.Context, T) sqsprocessor.ProcessResult

CustomProcessFunc describes a sqsprocessor.ProcessFunc which operates on a concrete, generic type.

type Decoder

type Decoder[T any] func(processFunc CustomProcessFunc[T]) sqsprocessor.ProcessFunc

Decoder describes any function which transforms a sqsprocessor.ProcessFunc into a CustomProcessFunc operating on a given generic type, T

type MessageAttributeValueCarrier

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

MessageAttributeValueCarrier implements opentelemetry's propagation.TextMapCarrier interface for injecting and extracting traces into sqs messages

func NewMessageAttributeValueCarrier

func NewMessageAttributeValueCarrier(init map[string]types.MessageAttributeValue) *MessageAttributeValueCarrier

NewMessageAttributeValueCarrier returns a pointer to a new MessageAttributeCarrier and can be initalised with a map of string to types.MessageAttributeValue, provide nil if using for injection

func (*MessageAttributeValueCarrier) Get

func (m *MessageAttributeValueCarrier) Get(key string) string

func (*MessageAttributeValueCarrier) Keys

func (m *MessageAttributeValueCarrier) Keys() (keys []string)

func (*MessageAttributeValueCarrier) Set

func (m *MessageAttributeValueCarrier) Set(key string, value string)