sqs

Documentation

Index

• func New() *sqs.SQS
• type API
  • func (a *API) IsEnabled() bool
  • func (a *API) SendMessage(ctx aws.Context, data []byte, queue string) (*sqs.SendMessageOutput, error)
  • func (a *API) SendMessageBatch(ctx aws.Context, data [][]byte, queue string) (*sqs.SendMessageBatchOutput, error)
  • func (a *API) Setup()

Functions

func New

func New() *sqs.SQS

New creates a new session for SQS

Types

type API

type API struct {
	Client sqsiface.SQSAPI
}

API wraps a Kinesis Firehose client interface

func (*API) IsEnabled

func (a *API) IsEnabled() bool

IsEnabled checks whether a new client has been set

func (*API) SendMessage

func (a *API) SendMessage(ctx aws.Context, data []byte, queue string) (*sqs.SendMessageOutput, error)

SendMessage is a convenience wrapper for sending a message to an SQS queue.

func (*API) SendMessageBatch

func (a *API) SendMessageBatch(ctx aws.Context, data [][]byte, queue string) (*sqs.SendMessageBatchOutput, error)

SendMessageBatch is a convenience wrapper for sending multiple messages to an SQS queue. This function becomes recursive for any messages that failed the SendMessage operation.

func (*API) Setup

func (a *API) Setup()

Setup creates a Kinesis Firehose client