messaging

Documentation

Index

• type Message
• type SNSAPI
• type SNSPublisher
  • func NewSNSPublisher(sns SNSAPI, prefix string) *SNSPublisher
  • func (p *SNSPublisher) Publish(ctx context.Context, msg Message) error

Types

type Message

type Message interface {
	MessagingTopic() string
	MessagingHeaders() map[string]string
	proto.Message
}

type SNSAPI

type SNSAPI interface {
	Publish(ctx context.Context, input *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)
}

type SNSPublisher

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

func NewSNSPublisher

func NewSNSPublisher(sns SNSAPI, prefix string) *SNSPublisher

func (*SNSPublisher) Publish

func (p *SNSPublisher) Publish(ctx context.Context, msg Message) error