sns

Documentation

Index

• func NewPublisher(snsClient *awsSns.Client, transformer MessageTransformer) (outbox.Publisher, error)
• type MessageTransformer
• type Publisher
  • func (p Publisher) Publish(ctx context.Context, message types.Message) error

Functions

func NewPublisher

func NewPublisher(snsClient *awsSns.Client, transformer MessageTransformer) (outbox.Publisher, error)

Types

type MessageTransformer

type MessageTransformer interface {
	Transform(message types.Message) (*sns.PublishInput, error)
}

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

func (Publisher) Publish

func (p Publisher) Publish(ctx context.Context, message types.Message) error