sqs

Documentation

Index

• func NewQueueProvider(options ...Option) goevents.QueueProvider
• type Option
  • func WithAwsConfig(awsConf *aws.Config) Option
  • func WithMappingSNSMessageEnabled() Option
  • func WithReceiveMaxNumberOfMessage(i int) Option
  • func WithReceiveWaitTimeSeconds(i int) Option

Functions

func NewQueueProvider

func NewQueueProvider(options ...Option) goevents.QueueProvider

Types

type Option

type Option func(conf *conf)

func WithAwsConfig

func WithAwsConfig(awsConf *aws.Config) Option

func WithMappingSNSMessageEnabled

func WithMappingSNSMessageEnabled() Option

If the events from the SQS queue are sourced from SNS, setting this option will automatically extract the SNS message as event's body.

func WithReceiveMaxNumberOfMessage

func WithReceiveMaxNumberOfMessage(i int) Option

func WithReceiveWaitTimeSeconds

func WithReceiveWaitTimeSeconds(i int) Option