sqsprocessor

Dec 27, 2023

Changes in this version

+ type Middleware func(ProcessFunc) ProcessFunc

Dec 15, 2023

Changes in this version

type Processor

+ func New(c SQSClienter, config ProcessorConfig) *Processor

Dec 13, 2023

Changes in this version

+ type ErrMessageExpired struct

+ func (e ErrMessageExpired) Error() string

+ type ProcessFunc func(ctx context.Context, msgBody string) ProcessResult

+ type ProcessResult uint8

+ const ProcessResultAck

+ const ProcessResultNack

+ type Processor struct

+ func NewProcessor(c SQSClienter, config ProcessorConfig) *Processor

+ func (p *Processor) Errors() <-chan error

+ func (p *Processor) Process(ctx context.Context, pf ProcessFunc)

+ type ProcessorConfig struct

+ Backoff time.Duration

+ NumWorkers int

+ Receive sqs.ReceiveMessageInput

+ ReceiveOptions []func(*sqs.Options)

+ type SQSClienter interface

+ ChangeMessageVisibility func(ctx context.Context, params *sqs.ChangeMessageVisibilityInput, ...) (*sqs.ChangeMessageVisibilityOutput, error)

+ DeleteMessage func(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)

+ ReceiveMessage func(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error)