notification

Documentation

Index

• func CreateTopic(n *sns.SNS, topicName string, timeoutDuration ...time.Duration) (topicArn string, err error)
• func ListTopics(n *sns.SNS, timeoutDuration ...time.Duration) (topicArnsList []string, err error)
• func NewNotificationAdapter(awsRegion awsregion.AWSRegion, httpOptions *awshttp2.HttpClientSettings) (*sns.SNS, error)
• func Publish(n *sns.SNS, topicArn string, message string, ...) (messageId string, err error)
• func Subscribe(n *sns.SNS, topicArn string, protocol snsprotocol.SNSProtocol, endPoint string, ...) (subscriptionArn string, err error)
• func Unsubscribe(n *sns.SNS, subscriptionArn string, timeoutDuration ...time.Duration) error

Functions

func CreateTopic

func CreateTopic(n *sns.SNS, topicName string, timeoutDuration ...time.Duration) (topicArn string, err error)

CreateTopic will create a new sns notification's topic

func ListTopics

func ListTopics(n *sns.SNS, timeoutDuration ...time.Duration) (topicArnsList []string, err error)

ListTopics will return list of all topic arns for the given sns object

func NewNotificationAdapter

func NewNotificationAdapter(awsRegion awsregion.AWSRegion, httpOptions *awshttp2.HttpClientSettings) (*sns.SNS, error)

NewNotificationAdapter creates a new sns service provider, and auto connect for use

func Publish

func Publish(n *sns.SNS, topicArn string, message string, attributes map[string]*snsaws.MessageAttributeValue, timeoutDuration ...time.Duration) (messageId string, err error)

Publish will publish a message to sns notification system for subscribers to consume

func Subscribe

func Subscribe(n *sns.SNS, topicArn string, protocol snsprotocol.SNSProtocol, endPoint string, timeoutDuration ...time.Duration) (subscriptionArn string, err error)

Subscribe will subscribe client to a sns notification's topic arn

func Unsubscribe

func Unsubscribe(n *sns.SNS, subscriptionArn string, timeoutDuration ...time.Duration) error

Unsubscribe will unsubscribe a subscription from sns notification system