NewBroker returns a broker that allows to push to AWS SNS topics and subscribe messages brokered by SQS.

WithDeliveryTimeout sets the max execution time a handler has to handle a message.

WithMaxMessages sets the maximum number of messages to return.

WithSNSClient sets the SNS client to be used by broker.

WithSQSClient sets the SQS client to be used by broker.

WithSQSQueueURL sets the SQS queue URL to be used by broker.

WithTopicsReloadInterval determines how often in-memory topics cache should be reloaded by connecting to AWS.

WithVisibilityTimeout sets the duration (in seconds) that the received messages are hidden from subsequent retrieve requests after being retrieved by a ReceiveMessage request.

WithWaitTimeSeconds sets the duration (in seconds) for which the call waits for a message to arrive in the queue before returning.

AWSSNSAPI captures the subset of the AWS SNS API that we need.

AWSSQSAPI captures the subset of the AWS SQS API that we need.

Option defines a function signature for configuration options.

Subscription represents a subscription to SNS topic.