middleware

package

v0.2.0 Latest Latest Go to latest Published: Dec 27, 2023 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func ContextFromMessageAttributes(next sqsprocessor.ProcessFunc) sqsprocessor.ProcessFunc

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

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[T any] func(context.Context, T) sqsprocessor.ProcessResult

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

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

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)

func (m MessageAttributeValueCarrier) ToMetadata() (ret middleware.Metadata)