sns

Documentation

Overview

Package sns handles interactions with aws-sdk-go/service/sns

Index

• Constants
• func NewPublishInput(input interface{}, messageAttributes map[string]interface{}, endpoint string) (*sns.PublishInput, error)
• func UnmarshalMessage(message string, input interface{}) error
• type Body
• type SNS
  • func New(svc *pkgAws.Session, endpoint string) (*SNS, error)
  • func (svc *SNS) SnsPublish(input interface{}, messageAttributes map[string]interface{}, targetArn string) (err error)

Constants

const (

	// ErrEmptyParameter is used when a required parameter is empty
	ErrEmptyParameter = "EmptyParameter"

	// ErrNoPointerParameter is used when a parameter is expected to be a pointer but it wasn't
	ErrNoPointerParameter = "NoPointerParameter"

	// ErrPointerParameterNotAllowed is used when a parameter is expected to be not a pointer but it wasn't
	ErrPointerParameterNotAllowed = "PointerParameterNotAllowed"
)

const (

	// MessageStructure represents the default MessageStructure for SNS
	MessageStructure = "json"
	// Endpoint represents the parameter named endpoint
	Endpoint = "endpoint"
	// Input represents the parameter named input
	Input = "input"
	// Message represents the parameter named message
	Message = "message"
)

Functions

func NewPublishInput

func NewPublishInput(input interface{}, messageAttributes map[string]interface{}, endpoint string) (*sns.PublishInput, error)

NewPublishInput returns a new *PublishInput given a body and an endpoint

func UnmarshalMessage

func UnmarshalMessage(message string, input interface{}) error

UnmarshalMessage unmarshal an SNS Message to a given interface

Types

type Body

type Body struct {
	Default string `json:"default"`
}

Body is used to initialize a valid SNS message

type SNS

type SNS struct {
	*sns.SNS
}

SNS embeds sns.SNS to be used to call New

func New

func New(svc *pkgAws.Session, endpoint string) (*SNS, error)

New returns a new *SNS embedding *sns.SNS

func (*SNS) SnsPublish

func (svc *SNS) SnsPublish(input interface{}, messageAttributes map[string]interface{}, targetArn string) (err error)

SnsPublish publishes an input on a given SNS targetArn