sns

Documentation

Index

• type ClientAPI
• type Publisher
  • func NewPublisher(api ClientAPI, topic string, opts ...func(cfg *PublisherConfig)) *Publisher
  • func (p *Publisher) Publish(ctx context.Context, events []event.Envelope) (err error)
• type PublisherConfig

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

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, events []event.Envelope) (err error)

Publish implements event.Publisher

type PublisherConfig

type PublisherConfig struct {
	Serializer event.Serializer
	// BatchEnabled if "true" the publisher groups record events in a single SNS message.
	BatchRecordEnabled bool
}