sqsworker

README

go-sqs-worker

Documentation

Index

• type Consumer
  • func NewConsumer() *Consumer
  • func NewConsumerWithClient(client sqsiface.SQSAPI) *Consumer
  • func (c *Consumer) Handle(queueURL string, handle HandlerFunc)
  • func (c *Consumer) Run()
  • func (c *Consumer) Shutdown(ctx context.Context) error
  • func (c *Consumer) Use(middleware ...MiddlewareFunc)
• type Context
• type ErrorHandlerFunc
• type HandlerFunc
• type MiddlewareFunc

Types

type Consumer

type Consumer struct {
	ErrorHandler ErrorHandlerFunc
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer() *Consumer

func NewConsumerWithClient

func NewConsumerWithClient(client sqsiface.SQSAPI) *Consumer

func (*Consumer) Handle

func (c *Consumer) Handle(queueURL string, handle HandlerFunc)

func (*Consumer) Run

func (c *Consumer) Run()

func (*Consumer) Shutdown

func (c *Consumer) Shutdown(ctx context.Context) error

func (*Consumer) Use

func (c *Consumer) Use(middleware ...MiddlewareFunc)

type Context

type Context interface {
	Context() context.Context
	WithContext(ctx context.Context) Context
	Message() *sqs.Message
	MessageBody() string
	Error(err error)
}

type ErrorHandlerFunc

type ErrorHandlerFunc func(c Context, err error)

type HandlerFunc

type HandlerFunc func(c Context) error

type MiddlewareFunc

type MiddlewareFunc func(next HandlerFunc) HandlerFunc