notify

Documentation

Index

• type Config
• type Notifier
• type SNSNotifier
  • func NewSNSNotifier(c Config, log log.Logger) (*SNSNotifier, error)
  • func (s *SNSNotifier) Push(message interface{}, attributes map[string]string) error

Types

type Config

type Config struct {
	Endpoint string `mapstructure:"endpoint"`
	TopicArn string `mapstructure:"topic_arn"`
	Enabled  bool   `mapstructure:"enabled"`
}

Config holds the required sqs config information.

type Notifier

type Notifier interface {
	Push(message interface{}, attributes map[string]string) error
}

Notifier represents a generic notifier API.

type SNSNotifier

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

SNSNotifier send push event to a sns topic.

func NewSNSNotifier

func NewSNSNotifier(c Config, log log.Logger) (*SNSNotifier, error)

NewSNSNotifier creates a new SNSNotifier with the given configuration.

func (*SNSNotifier) Push

func (s *SNSNotifier) Push(message interface{}, attributes map[string]string) error

Push pushes a notification to the configured sns topic.