queue

Aug 20, 2020

Changes in this version

+ var BackoffStrategy = func() backoff.BackOff

+ var ErrHandler = func(ctx context.Context, event string, err error)

+ var ErrMissingConsumerQueue = errors.New("missing consumer queue name")

+ var ErrMissingConsumerQueueURL = errors.New("missing consumer queue url")

+ var ErrMissingProducerQueue = errors.New("missing producer queue name")

+ var ErrMissingRegion = errors.New("missing queue region")

+ type HandlerFunc func(ctx context.Context, cfg config.Configuration, msg *message.MessageSQS) error

+ type InvalidBlockError struct

+ MessageID string

+ func (q *InvalidBlockError) Error() string

+ type Message struct

+ Artifacts []string

+ Bucket string

+ ID string

+ Service string

+ Type string

+ type MissingHandlerError struct

+ MessageType string

+ func (q *MissingHandlerError) Error() string

+ type Queue struct

+ func New(cfg *config.Configuration, hs HandlerFunc) (*Queue, error)

+ func (q *Queue) Close()

+ func (q *Queue) Start(ctx context.Context)