Versions in this module Expand all Collapse all v3 v3.0.3 Sep 22, 2020 Changes in this version + func CreateSqsClient(awsConfigs ...*aws.Config) sqsiface.SQSAPI + type Config struct + MaxNumberOfMessage int64 + MessageAttributeNames []string + QueueName string + QueueURL string + WaitTimeSecond 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 InvalidEventError struct + func NewInvalidEventError(event, msg string) InvalidEventError + func (e InvalidEventError) Error() string + type LoggerIFace interface + Debug func(i ...interface{}) + Error func(i ...interface{}) + Info func(i ...interface{}) + type Worker struct + Config *Config + Log LoggerIFace + SqsClient sqsiface.SQSAPI + func New(client sqsiface.SQSAPI, config *Config) *Worker + func (worker *Worker) Start(ctx context.Context, h Handler)