queue

Documentation

Index

• type SQSAdapter
  • func NewSQSAdapter(client *sqs.SQS) *SQSAdapter
  • func (qa *SQSAdapter) Listen(service *types.Service) (<-chan *types.Response, error)
  • func (qa *SQSAdapter) ListenWithOpts(service *types.Service, opts types.Options) (<-chan *types.Response, error)
  • func (qa *SQSAdapter) Queue(service *types.Service, request types.Request) (string, error)
  • func (qa *SQSAdapter) QueueWithOpts(service *types.Service, request types.Request, opts types.Options) (string, error)

Types

type SQSAdapter

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

SQSAdapter is an implementation of a QueueAdapter using AWS SQS

func NewSQSAdapter

func NewSQSAdapter(client *sqs.SQS) *SQSAdapter

NewSQSAdapter creates a new implementation of a SQSAdapter

func (*SQSAdapter) Listen

func (qa *SQSAdapter) Listen(service *types.Service) (<-chan *types.Response, error)

Listen listens for messages

func (*SQSAdapter) ListenWithOpts

func (qa *SQSAdapter) ListenWithOpts(service *types.Service, opts types.Options) (<-chan *types.Response, error)

ListenWithOpts listens for messages, with options

func (*SQSAdapter) Queue

func (qa *SQSAdapter) Queue(service *types.Service, request types.Request) (string, error)

Queue queues a message

func (*SQSAdapter) QueueWithOpts

func (qa *SQSAdapter) QueueWithOpts(service *types.Service, request types.Request, opts types.Options) (string, error)

QueueWithOpts queues a message, with options.