listener

package

v0.0.0-...-b8ff64e Latest Latest Go to latest Published: Jan 30, 2018 License: MIT Imports: 7 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

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

This section is empty.

This section is empty.

This section is empty.

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

DedupSQSFilter filters messages if they are a recent duplicate

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

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 (f *DedupSQSFilter) Filter(msg *sqs.Message) bool

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

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

SQSFilter will perform a predicate on messages

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

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

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

func (l *SQSListener) Close()

func (l *SQSListener) Listen(qName string)