sns

Documentation

Index

• Constants
• func CheckARNTopic(ctx context.Context, snsClient *sns.Client, topicARN string) (*string, error)
• func CreateSNS(ctx context.Context, snsClient *sns.Client, topicARN string, ...) (*string, error)
• type DefaultMarshalerUnmarshaler
  • func (d DefaultMarshalerUnmarshaler) Marshal(msg *message.Message) *sns.PublishInput
• type Marshaler
• type Publisher
  • func NewPublisher(config PublisherConfig, logger watermill.LoggerAdapter) (*Publisher, error)
  • func (p Publisher) AddSubscription(ctx context.Context, config *sns.SubscribeInput) error
  • func (p Publisher) Close() error
  • func (p Publisher) GetArnTopic(ctx context.Context, topic string) (*string, error)
  • func (p Publisher) Publish(topic string, messages ...*message.Message) error
• type PublisherConfig
• type SNSConfigAtrributes
  • func (s SNSConfigAtrributes) Attributes() map[string]string

Constants

const UUIDAttribute = "UUID"

Functions

func CheckARNTopic

func CheckARNTopic(ctx context.Context, snsClient *sns.Client, topicARN string) (*string, error)

func CreateSNS

func CreateSNS(ctx context.Context, snsClient *sns.Client, topicARN string, createSNSParams sns.CreateTopicInput) (*string, error)

Types

type DefaultMarshalerUnmarshaler

type DefaultMarshalerUnmarshaler struct{}

func (DefaultMarshalerUnmarshaler) Marshal

func (d DefaultMarshalerUnmarshaler) Marshal(msg *message.Message) *sns.PublishInput

type Marshaler

type Marshaler interface {
	Marshal(msg *message.Message) *sns.PublishInput
}

type Publisher

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

func NewPublisher

func NewPublisher(config PublisherConfig, logger watermill.LoggerAdapter) (*Publisher, error)

func (Publisher) AddSubscription

func (p Publisher) AddSubscription(ctx context.Context, config *sns.SubscribeInput) error

func (Publisher) Close

func (p Publisher) Close() error

func (Publisher) GetArnTopic

func (p Publisher) GetArnTopic(ctx context.Context, topic string) (*string, error)

func (Publisher) Publish

func (p Publisher) Publish(topic string, messages ...*message.Message) error

type PublisherConfig

type PublisherConfig struct {
	AWSConfig             aws.Config
	CreateTopicConfig     SNSConfigAtrributes
	CreateTopicfNotExists bool
	Marshaler             Marshaler
}

type SNSConfigAtrributes

type SNSConfigAtrributes struct {
	DeliveryPolicy            string `json:"DeliveryPolicy,omitempty"`
	DisplayName               string `json:"DisplayName,omitempty"`
	Policy                    string `json:"Policy,omitempty"`
	SignatureVersion          string `json:"SignatureVersion,omitempty"`
	TracingConfig             string `json:"TracingConfig,omitempty"`
	KmsMasterKeyId            string `json:"KmsMasterKeyId,omitempty"`
	FifoTopic                 string `json:"FifoTopic,omitempty"`
	ContentBasedDeduplication string `json:"ContentBasedDeduplication,omitempty"`
}

func (SNSConfigAtrributes) Attributes

func (s SNSConfigAtrributes) Attributes() map[string]string