messages

Documentation

Index

• type Acknowledger
• type Consumer
• type ErrorCallback
• type Message
  • func NewMessage(payload []byte, acknowledger Acknowledger) Message
  • func (m Message) Acknowledger() Acknowledger
  • func (m Message) Payload() []byte
• type NackOpts
• type Processor
  • func NewProcessor[Handler any](messageConsumer Consumer, eventsDeserializer events.Deserializer[Handler], ...) *Processor[Handler]
  • func (p *Processor[Handler]) Start(ctx context.Context) error
• type ProcessorOpt
  • func WithErrorCallback(errorCallback ErrorCallback) ProcessorOpt
  • func WithProcessingTimeout(processingTimeout time.Duration) ProcessorOpt
• type ProcessorOpts

Types

type Acknowledger

type Acknowledger interface {
	Ack() error
	Nack(opts NackOpts) error
}

type Consumer

type Consumer interface {
	Consume() (<-chan Message, error)
	Close() error
}

type ErrorCallback

type ErrorCallback func(processingError errors.ProcessingError)

type Message

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

func NewMessage

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

func (Message) Acknowledger

func (m Message) Acknowledger() Acknowledger

func (Message) Payload

func (m Message) Payload() []byte

type NackOpts

type NackOpts struct {
	Requeue      bool
	ErrorCode    errors.ErrorCode
	ErrorMessage string
}

type Processor

type Processor[Handler any] struct {
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor[Handler any](
	messageConsumer Consumer,
	eventsDeserializer events.Deserializer[Handler],
	eventsHandler Handler,
	customOpts ...ProcessorOpt,
) *Processor[Handler]

func (*Processor[Handler]) Start

func (p *Processor[Handler]) Start(ctx context.Context) error

type ProcessorOpt

type ProcessorOpt func(opts *ProcessorOpts)

func WithErrorCallback

func WithErrorCallback(errorCallback ErrorCallback) ProcessorOpt

func WithProcessingTimeout

func WithProcessingTimeout(processingTimeout time.Duration) ProcessorOpt

type ProcessorOpts

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