sqs

package
v0.0.0-...-680ee72 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2022 License: MIT, GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewSQSEventEmitter

func NewSQSEventEmitter(s *session.Session, queueName string) (emitter msgqueue.EventEmitter, err error)

func NewSQSListener

func NewSQSListener(s *session.Session, queueName string, maxMsgs, wtTime, visTO int64) (listener msgqueue.EventListener, err error)

Types

type SQSEmitter

type SQSEmitter struct {
	QueueURL *string
	// contains filtered or unexported fields
}

func (*SQSEmitter) Emit

func (sqsEmit *SQSEmitter) Emit(event msgqueue.Event) error

type SQSListener

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

func (*SQSListener) Listen

func (sqsListener *SQSListener) Listen(events ...string) (<-chan msgqueue.Event, <-chan error, error)

func (*SQSListener) Mapper

func (sqsListener *SQSListener) Mapper() msgqueue.EventMapper

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL