async

Documentation

Index

• func DetermineDecoder(contentType string) (encoding.DecodeRaw, error)
• type Message
  • func NewMessage(d []byte, dec encoding.DecodeRaw) *Message
  • func (m *Message) Decode(v interface{}) error
• type MockProcessor
  • func (mp MockProcessor) Process(ctx context.Context, msg *Message) error
• type ProcessorFunc

Functions

func DetermineDecoder

func DetermineDecoder(contentType string) (encoding.DecodeRaw, error)

DetermineDecoder determines the decoder based on the content type.

Types

type Message

type Message struct {
	Data []byte
	// contains filtered or unexported fields
}

Message definition of a async message.

func NewMessage

func NewMessage(d []byte, dec encoding.DecodeRaw) *Message

NewMessage creates a new message.

func (*Message) Decode

func (m *Message) Decode(v interface{}) error

Decode a the raw message into the given value.

type MockProcessor

type MockProcessor struct {
}

MockProcessor definition for test usage

func (MockProcessor) Process

func (mp MockProcessor) Process(ctx context.Context, msg *Message) error

Process a message for testing purposes

type ProcessorFunc

type ProcessorFunc func(context.Context, *Message) error

ProcessorFunc definition of a async processor.