messages

Jun 8, 2024

Changes in this version

+ type Acknowledger interface

+ Ack func() error

+ Nack func(opts NackOpts) error

+ type ErrorCallback func(processingError errors.ProcessingError)

type Message

+ func NewMessage(payload []byte, acknowledger Acknowledger) Message

+ func (m Message) Acknowledger() Acknowledger

+ type NackOpts struct

+ ErrorCode errors.ErrorCode

+ ErrorMessage string

+ Requeue bool

+ type ProcessorOpt func(opts *ProcessorOpts)

+ func WithErrorCallback(errorCallback ErrorCallback) ProcessorOpt

+ func WithProcessingTimeout(processingTimeout time.Duration) ProcessorOpt

+ type ProcessorOpts struct

May 1, 2024

Changes in this version

+ type Consumer interface

+ Close func() error

+ Consume func() (<-chan Message, error)

+ type Message struct

+ Payload []byte

+ type MockConsumer struct

+ func NewMockConsumer(t interface{ ... }) *MockConsumer

+ func (_m *MockConsumer) Close() error

+ func (_m *MockConsumer) Consume() (<-chan Message, error)

+ func (_m *MockConsumer) EXPECT() *MockConsumer_Expecter

+ type MockConsumer_Close_Call struct

+ func (_c *MockConsumer_Close_Call) Return(_a0 error) *MockConsumer_Close_Call

+ func (_c *MockConsumer_Close_Call) Run(run func()) *MockConsumer_Close_Call

+ func (_c *MockConsumer_Close_Call) RunAndReturn(run func() error) *MockConsumer_Close_Call

+ type MockConsumer_Consume_Call struct

+ func (_c *MockConsumer_Consume_Call) Return(_a0 <-chan Message, _a1 error) *MockConsumer_Consume_Call

+ func (_c *MockConsumer_Consume_Call) Run(run func()) *MockConsumer_Consume_Call

+ func (_c *MockConsumer_Consume_Call) RunAndReturn(run func() (<-chan Message, error)) *MockConsumer_Consume_Call

+ type MockConsumer_Expecter struct

+ func (_e *MockConsumer_Expecter) Close() *MockConsumer_Close_Call

+ func (_e *MockConsumer_Expecter) Consume() *MockConsumer_Consume_Call

+ type Processor struct

+ func NewProcessor[Visitor any](messageConsumer Consumer, eventsDeserializer events.Deserializer[Visitor], ...) *Processor[Visitor]

+ func (p *Processor[Visitor]) Start() error