listener

Documentation

Overview

Package listener provides an SQS listener which calls a function on each message. After the handler is complete, listener deletes the message.

Index

• type DedupSQSFilter
  • func NewDedupSQSFilter(maxEntries int, lifetime time.Duration) *DedupSQSFilter
  • func (f *DedupSQSFilter) Failed(msg *sqs.Message)
  • func (f *DedupSQSFilter) Filter(msg *sqs.Message) bool
• type SQSFilter
• type SQSHandler
• type SQSListener
  • func BuildSQSListener(handler SQSHandler, pollInterval time.Duration, client sqsiface.SQSAPI, ...) *SQSListener
  • func (l *SQSListener) Close()
  • func (l *SQSListener) Listen(qName string)

Types

type DedupSQSFilter

type DedupSQSFilter struct {
	// contains filtered or unexported fields
}

DedupSQSFilter filters messages if they are a recent duplicate

func NewDedupSQSFilter

func NewDedupSQSFilter(maxEntries int, lifetime time.Duration) *DedupSQSFilter

func (*DedupSQSFilter) Failed

func (f *DedupSQSFilter) Failed(msg *sqs.Message)

Failed will cleanup state of DedupSQSFilter when a message fails processing in this case it should be purged from the cache

func (*DedupSQSFilter) Filter

func (f *DedupSQSFilter) Filter(msg *sqs.Message) bool

Filter will return false to filter out messages if they are a recent duplicate

type SQSFilter

type SQSFilter interface {
	Filter(*sqs.Message) bool
	Failed(*sqs.Message)
}

SQSFilter will perform a predicate on messages

type SQSHandler

type SQSHandler interface {
	Handle(*sqs.Message) error
}

type SQSListener

type SQSListener struct {
	Handler SQSHandler
	// contains filtered or unexported fields
}

func BuildSQSListener

func BuildSQSListener(handler SQSHandler, pollInterval time.Duration, client sqsiface.SQSAPI, filter SQSFilter) *SQSListener

func (*SQSListener) Close

func (l *SQSListener) Close()

func (*SQSListener) Listen

func (l *SQSListener) Listen(qName string)