sqs

Documentation

Index

• Constants
• func NewEventEmitter(sess *session.Session, config Config) (queue.EventEmitter, error)
• func NewEventListener(sess *session.Session, config Config) (queue.EventListener, error)
• type Config

Constants

const (
	MessageGroupIDAuth = "auth"
)

Functions

func NewEventEmitter

func NewEventEmitter(sess *session.Session, config Config) (queue.EventEmitter, error)

func NewEventListener

func NewEventListener(sess *session.Session, config Config) (queue.EventListener, error)

Types

type Config

type Config struct {
	QueueName                 string
	ContentBasedDeduplication string
	DelaySeconds              string
	MessageRetentionPeriod    string
	MaxNumberOfMessages       int64
	VisibilityTimeout         int64
	WaitTimeSeconds           int64
}