sqsbatch

Documentation

Index

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

Functions

func DeleteMessageBatch

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

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.