Versions in this module Expand all Collapse all v1 v1.0.0 Jan 31, 2021 Changes in this version + const DefaultBatchDeleteMaxMessages + const DefaultConcurrency + const DefaultDeletionInterval + const DefaultMaxNumberOfMessages + const DefaultPublishInterval + const DefaultVisibilityTimeout + const DefaultWaitTimeSeconds + const MaxVisibilityTimeout + const MessageAttributeNamePartitionKey + const MessageAttributeNameRoute + var DefaultRetryPolicy = &defaultRetryPolicy + var PublisherDefaults = func(p *Publisher) + var WithPartitionedProcessor = func(s *Server) + func ChangeVisibilityWithRetryPolicy(m *Message) error + func ServerDefaults(s *Server) + func WithClient(c sqsiface.SQSAPI) func(s *Server) + func WithConcurrency(c int) func(s *Server) + type BoundedProcessor struct + Server *Server + func (p *BoundedProcessor) Process(messagesCh <-chan *Message, deletionsCh chan<- *Message, errorsCh chan<- error, ...) + type Handler interface + HandleMessage func(*Message) error + func RootHandler(h Handler) Handler + type HandlerFunc func(*Message) error + func (h HandlerFunc) HandleMessage(m *Message) error + type Logger interface + Println func(...interface{}) + type Message struct + QueueURL string + RetryPolicy RetryPolicy + SQSMessage *sqs.Message + func NewMessage(queueURL string, sqsMessage *sqs.Message, client sqsiface.SQSAPI) *Message + func (m *Message) ChangeVisibility(timeout *int64) error + func (m *Message) Context() context.Context + func (m *Message) Delete() error + func (m *Message) WithContext(ctx context.Context) *Message + type PartitionedProcessor struct + Server *Server + func (p *PartitionedProcessor) Process(messagesCh <-chan *Message, deletionsCh chan<- *Message, errorsCh chan<- error, ...) + type Processor interface + Process func(messagesCh <-chan *Message, deletionsCh chan<- *Message, errorsCh chan<- error, ...) + type Publisher struct + BatchMaxMessages int + Client sqsiface.SQSAPI + Logger Logger + OutputHandler func(*sqs.SendMessageBatchOutput, error) + PublishInterval time.Duration + QueueURL string + func NewPublisher(queueURL string, opts ...PublisherOpt) *Publisher + func (p *Publisher) Publish(entry *sqs.SendMessageBatchRequestEntry) + func (p *Publisher) Shutdown(ctx context.Context) error + func (p *Publisher) Start() + type PublisherOpt func(*Publisher) + type RetryPolicy interface + Delay func(receiveCount int) *int64 + type Router struct + Resolver func(*Message) (string, bool) + func NewRouter() *Router + func (r *Router) Handle(route string, h Handler) + func (r *Router) HandleMessage(m *Message) error + type Server struct + AttributeNames []*string + BatchDeleteMaxMessages int + Client sqsiface.SQSAPI + Concurrency int + DeletionInterval time.Duration + ErrorHandler func(error) + Handler Handler + Logger Logger + MaxNumberOfMessages *int64 + MessageAttributeNames []*string + Processor Processor + QueueURL string + VisibilityTimeout *int64 + WaitTimeSeconds *int64 + func NewServer(queueURL string, h Handler, opts ...func(*Server)) *Server + func (c *Server) Shutdown(ctx context.Context) error + func (c *Server) Start() + type ServerGroup struct + Servers []*Server + func (sg *ServerGroup) Shutdown(ctx context.Context) <-chan error + func (sg *ServerGroup) Start() + type UnBoundedProcessor struct + Server *Server + func (p *UnBoundedProcessor) Process(messagesCh <-chan *Message, deletionsCh chan<- *Message, errorsCh chan<- error, ...)
Go to main page