async

Mar 6, 2020

Changes in this version

+ type Builder struct

+ func (cb *Builder) Create() (*Component, error)

+ func (cb *Builder) WithFailureStrategy(fs FailStrategy) *Builder

+ func (cb *Builder) WithRetries(retries uint) *Builder

+ func (cb *Builder) WithRetryWait(retryWait time.Duration) *Builder

type Message

+ Source func() string

May 29, 2019

Changes in this version

type Component

+ func (c *Component) Info() map[string]interface{}

type Consumer

+ Info func() map[string]interface{}

+ type ConsumerFactory interface

+ Create func() (Consumer, error)

+ type FailStrategy int

+ const AckStrategy

+ const NackExitStrategy

+ const NackStrategy

+ func (fs FailStrategy) String() string

+ type OptionFunc func(*Component) error

+ func ConsumerRetry(retries int, retryWait time.Duration) OptionFunc

+ func FailureStrategy(fs FailStrategy) OptionFunc

Jul 31, 2018

Changes in this version

+ type Component struct

+ func New(name string, p ProcessorFunc, cns Consumer) (*Component, error)

+ func (c *Component) Run(ctx context.Context) error

+ func (c *Component) Shutdown(ctx context.Context) error

+ type Consumer interface

+ Close func() error

+ Consume func(context.Context) (<-chan Message, <-chan error, error)

type Message

+ Ack func() error

+ Context func() context.Context

+ Nack func() error

Jun 22, 2018

Changes in this version

type Message

+ Data []byte

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

Jun 4, 2018

Changes in this version

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

+ type Message struct

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

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

+ type MockProcessor struct

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

Apr 29, 2018

Changes in this version

+ type MessageProcessor interface

+ Process func(context.Context, []byte) error

+ type MockMesssageProcessor struct

+ func (mmp MockMesssageProcessor) Process(ctx context.Context, msg []byte) error

+ type Processor interface

+ Process func(context.Context) error