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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateTopic ¶ added in v1.0.6
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 ¶ added in v1.0.6
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 ¶ added in v1.0.6
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
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.