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

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

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

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.

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

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

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

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

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