sqsbatch

Documentation

Index

• func DeleteMessageBatch(sqsClient sqsiface.SQSAPI, queueURL string, messageReceipts []*string)
• func ReceiveMessage(sqsClient sqsiface.SQSAPI, queueURL string, waitTimeSeconds int64) (messages []*sqs.Message, messageReceipts []*string, err error)
• func SendMessageBatch(client sqsiface.SQSAPI, maxElapsedTime time.Duration, ...) ([]*sqs.SendMessageBatchRequestEntry, error)

Functions

func DeleteMessageBatch

func DeleteMessageBatch(sqsClient sqsiface.SQSAPI, queueURL string, messageReceipts []*string)

func ReceiveMessage

func ReceiveMessage(sqsClient sqsiface.SQSAPI, queueURL string, waitTimeSeconds int64) (messages []*sqs.Message,
	messageReceipts []*string, err error)

func SendMessageBatch

func SendMessageBatch(
	client sqsiface.SQSAPI,
	maxElapsedTime time.Duration,
	input *sqs.SendMessageBatchInput,
) ([]*sqs.SendMessageBatchRequestEntry, error)

SendMessageBatch sends messages to SQS with paging, backoff, and auto-retry for failed items.