Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientAPI ¶
type ClientAPI interface {
Publish(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)
}
type Publisher ¶
type Publisher struct { *PublisherConfig // contains filtered or unexported fields }
func NewPublisher ¶
func NewPublisher(api ClientAPI, topic string, opts ...func(cfg *PublisherConfig)) *Publisher
type PublisherConfig ¶
type PublisherConfig struct { Serializer event.Serializer // BatchEnabled if "true" the publisher groups record events in a single SNS message. BatchRecordEnabled bool }
Click to show internal directories.
Click to hide internal directories.