sqs

Documentation

Index

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

Functions

func New

func New(cfg iaws.Config) *sqs.SQS

New returns a configured SQS client.

Types

type API

type API struct {
	Client sqsiface.SQSAPI
}

API wraps an SQS 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, queue string, data []byte) (*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, queue string, data [][]byte) (*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(cfg iaws.Config)

Setup creates an SQS client.