sqspoller

Feb 24, 2020

Changes in this version

+ var ErrNotCloseable = errors.New("ErrNotCloseable: poller is either stopped or already shutting down")

+ var ErrNotRunnable = errors.New("ErrNotRunnable: poller is either already running or shutting down")

Feb 7, 2020

Changes in this version

+ var ErrRequestTimeout = errors.New("ErrRequestTimeout: requesting message from queue timed out")

type Poller

+ RequestTimeout time.Duration

+ func (p *Poller) SetRequestTimeout(t time.Duration)

+ type TrackingValue struct

+ Now time.Time

+ TraceID string

Feb 2, 2020

Changes in this version

+ const TrackingKey

+ var ErrNoErrorHandler = errors.New("ErrNoErrorHandler: no error handler set on poller instance")

+ var ErrNoMessageHandler = errors.New("ErrNoMessageHandler: no message handler set on poller instance")

+ type ErrorHandler func(ctx context.Context, err error) error

+ type MessageHandler func(ctx context.Context, client *sqs.SQS, msgOutput *MessageOutput) error

type Poller

+ CurrentInterval time.Duration

+ IdlePollInterval time.Duration

+ func (p *Poller) OnError(handler ErrorHandler)

+ func (p *Poller) OnMessage(handler MessageHandler, middleware ...Middleware)

+ func (p *Poller) SetIdlePollInterval(t time.Duration)

+ type TackingValue struct

+ Now time.Time

+ TraceID string

Jan 20, 2020

Changes in this version

+ var ErrAlreadyRunning = errors.New("ErrAlreadyShuttingDown: poller is already running")

+ var ErrAlreadyShuttingDown = errors.New("ErrAlreadyShuttingDown: poller is already in the process of shutting down")

+ var ErrNoReceiveMessageParams = errors.New("ErrNoReceiveMessageParams: no ReceiveMessage parameters have been set")

type Middleware

+ func HandlerTimeout(t time.Duration) Middleware

type Poller

+ func (p *Poller) ReceiveMessageParams(input *sqs.ReceiveMessageInput, opts ...request.Option)

Jan 17, 2020

Changes in this version

+ var ErrHandlerTimeout = errors.New("ErrHandlerTimeout: handler took to long to process message")

+ type CtxTackingValue struct

+ Now time.Time

+ TraceID string

type Middleware

+ func Tracking() Middleware

type Poller

+ HandlerTimeout time.Duration

+ LastPollTime time.Time

+ PollInterval time.Duration

+ func (p *Poller) SetHandlerTimeout(t time.Duration)

+ func (p *Poller) SetPollInterval(t time.Duration)

Jan 16, 2020

Changes in this version

+ const CtxKey

+ var ErrIntegrityIssue = errors.New("ErrIntegrityIssue: unknown integrity issue")

+ var ErrNoHandler = errors.New("ErrNoHandler: no handler set on Poller instance")

+ var ErrShutdownGraceful = errors.New("ErrShutdownGraceful: poller could not shutdown gracefully in time")

+ var ErrShutdownNow = errors.New("ErrShutdownNow: poller was suddenly shutdown")

+ var ErrTimeoutHandling = errors.New("ErrTimeoutHandling: handler took to long to process message")

+ var ErrTimeoutNoMessages = errors.New("ErrTimeoutNoMessages: no new messages in given time frame")

+ var ErrTimeoutShutdown = errors.New("ErrTimeoutShutdown: could not shut down gracefully")

+ type CtxValue struct

+ Now time.Time

+ TraceID string

+ type DeleteMessageOutput struct

+ type Handler func(ctx context.Context, msgOutput *MessageOutput, err error) error

+ type Message struct

+ func (m *Message) Delete() (*DeleteMessageOutput, error)

+ type MessageOutput struct

+ Messages []*Message

+ type Middleware func(Handler) Handler

+ func IgnoreEmptyResponses() Middleware

+ type Poller struct

+ Interval time.Duration

+ TimeoutHandling time.Duration

+ func Default(sqsSvc *sqs.SQS, config sqs.ReceiveMessageInput, options ...request.Option) *Poller

+ func New(sqsSvc *sqs.SQS, config sqs.ReceiveMessageInput, options ...request.Option) *Poller

+ func (p *Poller) Handle(handler Handler, middleware ...Middleware)

+ func (p *Poller) Run() error

+ func (p *Poller) SetInterval(t time.Duration)

+ func (p *Poller) SetTimeoutHandling(t time.Duration)

+ func (p *Poller) ShutdownAfter(t time.Duration) error

+ func (p *Poller) ShutdownGracefully() error

+ func (p *Poller) ShutdownNow() error

+ func (p *Poller) Use(middleware ...Middleware)