aws

Documentation

Index

• func BindAttributes(attributes map[string]interface{}) (map[string]*sns.MessageAttributeValue, error)
• type AWSPubSubAdapter
  • func NewAWSPubSubAdapter(region string, accessKeyId string, secretAccessKey string) (*AWSPubSubAdapter, error)
  • func (ps *AWSPubSubAdapter) PollMessages(topicARN string, handler func(message string) error) error
  • func (ps *AWSPubSubAdapter) Publish(topicARN string, message interface{}, messageAttributes map[string]interface{}, ...) error

Functions

func BindAttributes

func BindAttributes(attributes map[string]interface{}) (map[string]*sns.MessageAttributeValue, error)

Types

type AWSPubSubAdapter

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

func NewAWSPubSubAdapter

func NewAWSPubSubAdapter(region string, accessKeyId string, secretAccessKey string) (*AWSPubSubAdapter, error)

func (*AWSPubSubAdapter) PollMessages

func (ps *AWSPubSubAdapter) PollMessages(topicARN string, handler func(message string) error) error

func (*AWSPubSubAdapter) Publish

func (ps *AWSPubSubAdapter) Publish(topicARN string, message interface{}, messageAttributes map[string]interface{}, isCompressed bool) error