listener

Mar 30, 2023

Changes in this version

+ type Listener struct

+ PollingInterval time.Duration

+ QueueName string

+ SnsClient SNSAPI

+ SqsClient SQSAPI

+ TopicArn string

+ Verbose bool

+ func New(topicArn string, snsClient SNSAPI, sqsClient SQSAPI, opts ...Option) *Listener

+ func (l *Listener) Listen(ctx context.Context, c Consumer) error

+ func (l *Listener) Setup(ctx context.Context) error

+ func (l *Listener) Teardown(ctx context.Context) error

+ type Option func(l *Listener)

+ func WithPollingInterval(pollingInterval time.Duration) Option

+ func WithQueueName(queueName string) Option

+ func WithVerbose(verbose bool) Option

Mar 26, 2023

Changes in this version

+ func ListenToTopic(ctx context.Context, sqsClient SQSAPI, snsClient SNSAPI, ssmClient SSMAPI, ...) error

+ type Consumer interface

+ OnError func(ctx context.Context, err error)

+ OnMessage func(ctx context.Context, msg MessageContent)

+ type ListenerConfiguration struct

+ ParameterPath string

+ PollingInterval time.Duration

+ QueueName string

+ TopicArn string

+ Verbose bool

+ type MessageContent struct

+ Body *string

+ Id *string

+ type SNSAPI interface

+ Subscribe func(ctx context.Context, params *sns.SubscribeInput, optFns ...func(*sns.Options)) (*sns.SubscribeOutput, error)

+ Unsubscribe func(ctx context.Context, params *sns.UnsubscribeInput, ...) (*sns.UnsubscribeOutput, error)

+ type SQSAPI interface

+ CreateQueue func(ctx context.Context, params *sqs.CreateQueueInput, ...) (*sqs.CreateQueueOutput, error)

+ DeleteMessage func(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)

+ DeleteQueue func(ctx context.Context, params *sqs.DeleteQueueInput, ...) (*sqs.DeleteQueueOutput, error)

+ GetQueueAttributes func(ctx context.Context, params *sqs.GetQueueAttributesInput, ...) (*sqs.GetQueueAttributesOutput, error)

+ ReceiveMessage func(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error)

+ type SSMAPI interface

+ GetParameter func(ctx context.Context, params *ssm.GetParameterInput, ...) (*ssm.GetParameterOutput, error)