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 Processor

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 {
	// 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 Processor

type Processor interface {
	Process(context.Context, *Message) error
}

Processor interface for implementing processing of messages