Versions in this module Expand all Collapse all v0 v0.0.1 Oct 8, 2022 Changes in this version + type BufferedClient struct + func NewBufferedClient(config Config) (*BufferedClient, error) + func (c *BufferedClient) DeleteMessageAsync(entries ...types.DeleteMessageBatchRequestEntry) error + func (c *BufferedClient) SendMessageAsync(entries ...types.SendMessageBatchRequestEntry) error + func (c *BufferedClient) Stats() Stats + func (c *BufferedClient) Stop() + type Config struct + DeleteBufferSize int + DeleteConcurrency int + DeleteWaitTime time.Duration + OnDeleteMessageBatch func(*sqs.DeleteMessageBatchOutput, error) + OnSendMessageBatch func(*sqs.SendMessageBatchOutput, error) + QueueURL string + SQSClient SQSClient + SendBufferSize int + SendConcurrency int + SendWaitTime time.Duration + type SQSClient interface + DeleteMessageBatch func(context.Context, *sqs.DeleteMessageBatchInput, ...func(*sqs.Options)) (*sqs.DeleteMessageBatchOutput, error) + SendMessageBatch func(context.Context, *sqs.SendMessageBatchInput, ...func(*sqs.Options)) (*sqs.SendMessageBatchOutput, error) + type Stats struct + DeleteMessageBatchCalls uint64 + MessagesDeleted uint64 + MessagesSent uint64 + SendMessageBatchCalls uint64
Go to main page