Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface { GetQueueUrl(context.Context, *sqs.GetQueueUrlInput, ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error) SendMessage(context.Context, *sqs.SendMessageInput, ...func(*sqs.Options)) (*sqs.SendMessageOutput, error) }
Client defines the AWS SQS methods used by the Publisher. This is used for testing purposes.
type Option ¶
type Option func(*Publisher)
Option is a function to set options to Publisher.
func WithDefaultOrderingKey ¶
WithDefaultOrderingKey setups the default ordering key.
func WithFifoQueue ¶
WithFifoQueue setups the flag to use fifo queue.
func WithMetaOrderingKey ¶
WithMetaOrderingKey setups the metadata key to get the ordering key.
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
Publisher handles the pubsub topic messages.
Click to show internal directories.
Click to hide internal directories.