Versions in this module Expand all Collapse all v2 v2.0.5 Apr 13, 2021 Changes in this version + type Config struct + Logger Logger + MaxNumberOfMessage int64 + QueueURL string + VisibilityTimeout int64 + WaitTimeSecond int64 + WorkerSize int64 + type Handler interface + HandleMessage func(msg *sqs.Message) error + type HandlerFunc func(msg *sqs.Message) error + func (f HandlerFunc) HandleMessage(msg *sqs.Message) error + type Logger interface + Debug func(args ...interface{}) + Error func(args ...interface{}) + Info func(args ...interface{}) + type Worker struct + type WorkerPool struct + func NewWorkerPool(ctx context.Context, conf *Config, sqsClient sqsiface.SQSAPI) *WorkerPool + func (w *WorkerPool) Run(handler Handler) + func (w *WorkerPool) WaitForWorkersDone()
Go to main page