sqs

May 29, 2024

Changes in this version

+ type API interface

+ DeleteMessageBatch func(ctx context.Context, params *sqs.DeleteMessageBatchInput, ...) (*sqs.DeleteMessageBatchOutput, error)

+ GetQueueUrl func(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error)

+ SendMessageBatch func(ctx context.Context, params *sqs.SendMessageBatchInput, ...) (*sqs.SendMessageBatchOutput, error)

+ func NewSQSProxy(client *sqs.Client) API

+ type MockAPI struct

+ func NewMockSQS(ctrl *gomock.Controller) *MockAPI

+ func (m *MockAPI) DeleteMessageBatch(ctx context.Context, params *sqs.DeleteMessageBatchInput, ...) (*sqs.DeleteMessageBatchOutput, error)

+ func (m *MockAPI) EXPECT() *MockAPIMockRecorder

+ func (m *MockAPI) GetQueueUrl(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error)

+ func (m *MockAPI) SendMessageBatch(ctx context.Context, params *sqs.SendMessageBatchInput, ...) (*sqs.SendMessageBatchOutput, error)

+ type MockAPIMockRecorder struct

+ func (mr *MockAPIMockRecorder) DeleteMessageBatch(ctx, params any, optFns ...any) *gomock.Call

+ func (mr *MockAPIMockRecorder) GetQueueUrl(ctx, params any, optFns ...any) *gomock.Call

+ func (mr *MockAPIMockRecorder) SendMessageBatch(ctx, params any, optFns ...any) *gomock.Call