sqs

Documentation

Index

• type API
  • func NewSQSProxy(client *sqs.Client) API
• type MockAPI
  • 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
  • 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

Types

type API

type API interface {
	SendMessageBatch(ctx context.Context, params *sqs.SendMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageBatchOutput, error)
	GetQueueUrl(ctx context.Context, params *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)
	DeleteMessageBatch(ctx context.Context, params *sqs.DeleteMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageBatchOutput, error)
}

func NewSQSProxy

func NewSQSProxy(client *sqs.Client) API

type MockAPI

type MockAPI struct {
	// contains filtered or unexported fields
}

MockAPI is a mock of API interface.

func NewMockSQS

func NewMockSQS(ctrl *gomock.Controller) *MockAPI

NewMockSQS creates a new mock instance.

func (*MockAPI) DeleteMessageBatch

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

DeleteMessageBatch mocks base method.

func (*MockAPI) EXPECT

func (m *MockAPI) EXPECT() *MockAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAPI) GetQueueUrl

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

GetQueueUrl mocks base method.

func (*MockAPI) SendMessageBatch

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

SendMessageBatch mocks base method.

type MockAPIMockRecorder

type MockAPIMockRecorder struct {
	// contains filtered or unexported fields
}

MockAPIMockRecorder is the mock recorder for MockAPI.

func (*MockAPIMockRecorder) DeleteMessageBatch

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

DeleteMessageBatch indicates an expected call of DeleteMessageBatch.

func (*MockAPIMockRecorder) GetQueueUrl

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

GetQueueUrl indicates an expected call of GetQueueUrl.

func (*MockAPIMockRecorder) SendMessageBatch

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

SendMessageBatch indicates an expected call of SendMessageBatch.