gosns

Documentation

Index

• Variables
• func ConfirmSubscription(w http.ResponseWriter, req *http.Request)
• func CreateMessageBody(subs *app.Subscription, msg string, subject string, messageStructure string, ...) ([]byte, error)
• func CreateTopic(w http.ResponseWriter, req *http.Request)
• func DeleteTopic(w http.ResponseWriter, req *http.Request)
• func GetSubscriptionAttributes(w http.ResponseWriter, req *http.Request)
• func ListSubscriptions(w http.ResponseWriter, req *http.Request)
• func ListSubscriptionsByTopic(w http.ResponseWriter, req *http.Request)
• func ListTopics(w http.ResponseWriter, req *http.Request)
• func Publish(w http.ResponseWriter, req *http.Request)
• func SendResponseBack(w http.ResponseWriter, req *http.Request, respStruct interface{}, ...)
• func SetSubscriptionAttributes(w http.ResponseWriter, req *http.Request)
• func Subscribe(w http.ResponseWriter, req *http.Request)
• func Unsubscribe(w http.ResponseWriter, req *http.Request)

Variables

var PemKEY []byte

var PrivateKEY *rsa.PrivateKey

var TOPIC_DATA map[string]*pendingConfirm

Functions

func ConfirmSubscription

func ConfirmSubscription(w http.ResponseWriter, req *http.Request)

func CreateMessageBody

func CreateMessageBody(subs *app.Subscription, msg string, subject string, messageStructure string,
	messageAttributes map[string]app.MessageAttributeValue) ([]byte, error)

func CreateTopic

func CreateTopic(w http.ResponseWriter, req *http.Request)

func DeleteTopic

func DeleteTopic(w http.ResponseWriter, req *http.Request)

func GetSubscriptionAttributes

func GetSubscriptionAttributes(w http.ResponseWriter, req *http.Request)

func ListSubscriptions

func ListSubscriptions(w http.ResponseWriter, req *http.Request)

func ListSubscriptionsByTopic

func ListSubscriptionsByTopic(w http.ResponseWriter, req *http.Request)

func ListTopics

func ListTopics(w http.ResponseWriter, req *http.Request)

func Publish

func Publish(w http.ResponseWriter, req *http.Request)

aws --endpoint-url http://localhost:47194 sns publish --topic-arn arn:aws:sns:yopa-local:000000000000:test1 --message "This is a test"

func SendResponseBack

func SendResponseBack(w http.ResponseWriter, req *http.Request, respStruct interface{}, content string)

func SetSubscriptionAttributes

func SetSubscriptionAttributes(w http.ResponseWriter, req *http.Request)

func Subscribe

func Subscribe(w http.ResponseWriter, req *http.Request)

aws --endpoint-url http://localhost:47194 sns subscribe --topic-arn arn:aws:sns:us-west-2:0123456789012:my-topic --protocol email --notification-endpoint my-email@example.com

func Unsubscribe

func Unsubscribe(w http.ResponseWriter, req *http.Request)