pubsub

Documentation

Index

• type SNSAdapter
  • func NewSNSAdapter(client *sns.SNS) *SNSAdapter
  • func (sa *SNSAdapter) Publish(service *types.Service, request types.Request) error
  • func (sa *SNSAdapter) PublishWithOpts(service *types.Service, request types.Request, opts types.Options) error
  • func (sa *SNSAdapter) Subscribe(service *types.Service) (<-chan *types.Response, error)
  • func (sa *SNSAdapter) SubscribeWithOpts(service *types.Service, opts types.Options) (<-chan *types.Response, error)

Types

type SNSAdapter

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

SNSAdapter is an implementation of a PubsubAdapter using AWS SNS

func NewSNSAdapter

func NewSNSAdapter(client *sns.SNS) *SNSAdapter

NewSNSAdapter creates a new SNSAdapter instance

func (*SNSAdapter) Publish

func (sa *SNSAdapter) Publish(service *types.Service, request types.Request) error

Publish publishes an event to a queue

func (*SNSAdapter) PublishWithOpts

func (sa *SNSAdapter) PublishWithOpts(service *types.Service, request types.Request, opts types.Options) error

PublishWithOpts takes the generic options type, converts to 'MessageAttributes'

func (*SNSAdapter) Subscribe

func (sa *SNSAdapter) Subscribe(service *types.Service) (<-chan *types.Response, error)

Subscribe is not implemented (subscriptions are at a higher, none code level for AWS, so we can't subscribe through code as such)

func (*SNSAdapter) SubscribeWithOpts

func (sa *SNSAdapter) SubscribeWithOpts(service *types.Service, opts types.Options) (<-chan *types.Response, error)

SubscribeWithOpts is not implemented (subscriptions are at a higher, none code level for AWS, so we can't subscribe through code as such)