snssqs

Nov 22, 2021

Changes in this version

+ func NewBroker(ctx context.Context, option ...Option) (pubsub.Broker, error)

+ type AWSSNSAPI interface

+ ListTagsForResource func(ctx context.Context, params *sns.ListTagsForResourceInput, ...) (*sns.ListTagsForResourceOutput, error)

+ ListTopics func(ctx context.Context, params *sns.ListTopicsInput, optFns ...func(*sns.Options)) (*sns.ListTopicsOutput, error)

+ Publish func(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)

+ 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 AWSSQSAPI interface

+ ChangeMessageVisibility func(ctx context.Context, params *sqs.ChangeMessageVisibilityInput, ...) (*sqs.ChangeMessageVisibilityOutput, error)

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

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

+ type Option interface

+ func WithDeliveryTimeout(t time.Duration) Option

+ func WithMaxMessages(n int32) Option

+ func WithSNSClient(snsClient AWSSNSAPI) Option

+ func WithSQSClient(sqsClient AWSSQSAPI) Option

+ func WithSQSQueueURL(sqsQueueURL string) Option

+ func WithTopicsReloadInterval(t time.Duration) Option

+ func WithVisibilityTimeout(t int32) Option

+ func WithWaitTimeSeconds(t int32) Option

+ type Subscription interface

+ ARN func() string