Documentation ¶
Index ¶
- type Client
- func (_m *Client) CreateQueue(ctx context.Context, params *sqs.CreateQueueInput, ...) (*sqs.CreateQueueOutput, error)
- func (_m *Client) DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, ...) (*sqs.DeleteMessageOutput, error)
- func (_m *Client) DeleteMessageBatch(ctx context.Context, params *sqs.DeleteMessageBatchInput, ...) (*sqs.DeleteMessageBatchOutput, error)
- func (_m *Client) EXPECT() *Client_Expecter
- func (_m *Client) GetQueueAttributes(ctx context.Context, params *sqs.GetQueueAttributesInput, ...) (*sqs.GetQueueAttributesOutput, error)
- func (_m *Client) GetQueueUrl(ctx context.Context, params *sqs.GetQueueUrlInput, ...) (*sqs.GetQueueUrlOutput, error)
- func (_m *Client) PurgeQueue(ctx context.Context, params *sqs.PurgeQueueInput, optFns ...func(*sqs.Options)) (*sqs.PurgeQueueOutput, error)
- func (_m *Client) ReceiveMessage(ctx context.Context, params *sqs.ReceiveMessageInput, ...) (*sqs.ReceiveMessageOutput, error)
- func (_m *Client) SendMessage(ctx context.Context, params *sqs.SendMessageInput, ...) (*sqs.SendMessageOutput, error)
- func (_m *Client) SendMessageBatch(ctx context.Context, params *sqs.SendMessageBatchInput, ...) (*sqs.SendMessageBatchOutput, error)
- func (_m *Client) SetQueueAttributes(ctx context.Context, params *sqs.SetQueueAttributesInput, ...) (*sqs.SetQueueAttributesOutput, error)
- type Client_CreateQueue_Call
- func (_c *Client_CreateQueue_Call) Return(_a0 *sqs.CreateQueueOutput, _a1 error) *Client_CreateQueue_Call
- func (_c *Client_CreateQueue_Call) Run(run func(ctx context.Context, params *sqs.CreateQueueInput, ...)) *Client_CreateQueue_Call
- func (_c *Client_CreateQueue_Call) RunAndReturn(...) *Client_CreateQueue_Call
- type Client_DeleteMessageBatch_Call
- func (_c *Client_DeleteMessageBatch_Call) Return(_a0 *sqs.DeleteMessageBatchOutput, _a1 error) *Client_DeleteMessageBatch_Call
- func (_c *Client_DeleteMessageBatch_Call) Run(run func(ctx context.Context, params *sqs.DeleteMessageBatchInput, ...)) *Client_DeleteMessageBatch_Call
- func (_c *Client_DeleteMessageBatch_Call) RunAndReturn(...) *Client_DeleteMessageBatch_Call
- type Client_DeleteMessage_Call
- func (_c *Client_DeleteMessage_Call) Return(_a0 *sqs.DeleteMessageOutput, _a1 error) *Client_DeleteMessage_Call
- func (_c *Client_DeleteMessage_Call) Run(run func(ctx context.Context, params *sqs.DeleteMessageInput, ...)) *Client_DeleteMessage_Call
- func (_c *Client_DeleteMessage_Call) RunAndReturn(...) *Client_DeleteMessage_Call
- type Client_Expecter
- func (_e *Client_Expecter) CreateQueue(ctx interface{}, params interface{}, optFns ...interface{}) *Client_CreateQueue_Call
- func (_e *Client_Expecter) DeleteMessage(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DeleteMessage_Call
- func (_e *Client_Expecter) DeleteMessageBatch(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DeleteMessageBatch_Call
- func (_e *Client_Expecter) GetQueueAttributes(ctx interface{}, params interface{}, optFns ...interface{}) *Client_GetQueueAttributes_Call
- func (_e *Client_Expecter) GetQueueUrl(ctx interface{}, params interface{}, optFns ...interface{}) *Client_GetQueueUrl_Call
- func (_e *Client_Expecter) PurgeQueue(ctx interface{}, params interface{}, optFns ...interface{}) *Client_PurgeQueue_Call
- func (_e *Client_Expecter) ReceiveMessage(ctx interface{}, params interface{}, optFns ...interface{}) *Client_ReceiveMessage_Call
- func (_e *Client_Expecter) SendMessage(ctx interface{}, params interface{}, optFns ...interface{}) *Client_SendMessage_Call
- func (_e *Client_Expecter) SendMessageBatch(ctx interface{}, params interface{}, optFns ...interface{}) *Client_SendMessageBatch_Call
- func (_e *Client_Expecter) SetQueueAttributes(ctx interface{}, params interface{}, optFns ...interface{}) *Client_SetQueueAttributes_Call
- type Client_GetQueueAttributes_Call
- func (_c *Client_GetQueueAttributes_Call) Return(_a0 *sqs.GetQueueAttributesOutput, _a1 error) *Client_GetQueueAttributes_Call
- func (_c *Client_GetQueueAttributes_Call) Run(run func(ctx context.Context, params *sqs.GetQueueAttributesInput, ...)) *Client_GetQueueAttributes_Call
- func (_c *Client_GetQueueAttributes_Call) RunAndReturn(...) *Client_GetQueueAttributes_Call
- type Client_GetQueueUrl_Call
- func (_c *Client_GetQueueUrl_Call) Return(_a0 *sqs.GetQueueUrlOutput, _a1 error) *Client_GetQueueUrl_Call
- func (_c *Client_GetQueueUrl_Call) Run(run func(ctx context.Context, params *sqs.GetQueueUrlInput, ...)) *Client_GetQueueUrl_Call
- func (_c *Client_GetQueueUrl_Call) RunAndReturn(...) *Client_GetQueueUrl_Call
- type Client_PurgeQueue_Call
- type Client_ReceiveMessage_Call
- func (_c *Client_ReceiveMessage_Call) Return(_a0 *sqs.ReceiveMessageOutput, _a1 error) *Client_ReceiveMessage_Call
- func (_c *Client_ReceiveMessage_Call) Run(run func(ctx context.Context, params *sqs.ReceiveMessageInput, ...)) *Client_ReceiveMessage_Call
- func (_c *Client_ReceiveMessage_Call) RunAndReturn(...) *Client_ReceiveMessage_Call
- type Client_SendMessageBatch_Call
- func (_c *Client_SendMessageBatch_Call) Return(_a0 *sqs.SendMessageBatchOutput, _a1 error) *Client_SendMessageBatch_Call
- func (_c *Client_SendMessageBatch_Call) Run(run func(ctx context.Context, params *sqs.SendMessageBatchInput, ...)) *Client_SendMessageBatch_Call
- func (_c *Client_SendMessageBatch_Call) RunAndReturn(...) *Client_SendMessageBatch_Call
- type Client_SendMessage_Call
- func (_c *Client_SendMessage_Call) Return(_a0 *sqs.SendMessageOutput, _a1 error) *Client_SendMessage_Call
- func (_c *Client_SendMessage_Call) Run(run func(ctx context.Context, params *sqs.SendMessageInput, ...)) *Client_SendMessage_Call
- func (_c *Client_SendMessage_Call) RunAndReturn(...) *Client_SendMessage_Call
- type Client_SetQueueAttributes_Call
- func (_c *Client_SetQueueAttributes_Call) Return(_a0 *sqs.SetQueueAttributesOutput, _a1 error) *Client_SetQueueAttributes_Call
- func (_c *Client_SetQueueAttributes_Call) Run(run func(ctx context.Context, params *sqs.SetQueueAttributesInput, ...)) *Client_SetQueueAttributes_Call
- func (_c *Client_SetQueueAttributes_Call) RunAndReturn(...) *Client_SetQueueAttributes_Call
- type Queue
- func (_m *Queue) DeleteMessage(ctx context.Context, receiptHandle string) error
- func (_m *Queue) DeleteMessageBatch(ctx context.Context, receiptHandles []string) error
- func (_m *Queue) EXPECT() *Queue_Expecter
- func (_m *Queue) GetArn() string
- func (_m *Queue) GetName() string
- func (_m *Queue) GetUrl() string
- func (_m *Queue) Receive(ctx context.Context, maxNumberOfMessages int32, waitTime int32) ([]types.Message, error)
- func (_m *Queue) Send(ctx context.Context, msg *sqs.Message) error
- func (_m *Queue) SendBatch(ctx context.Context, messages []*sqs.Message) error
- type Queue_DeleteMessageBatch_Call
- func (_c *Queue_DeleteMessageBatch_Call) Return(_a0 error) *Queue_DeleteMessageBatch_Call
- func (_c *Queue_DeleteMessageBatch_Call) Run(run func(ctx context.Context, receiptHandles []string)) *Queue_DeleteMessageBatch_Call
- func (_c *Queue_DeleteMessageBatch_Call) RunAndReturn(run func(context.Context, []string) error) *Queue_DeleteMessageBatch_Call
- type Queue_DeleteMessage_Call
- func (_c *Queue_DeleteMessage_Call) Return(_a0 error) *Queue_DeleteMessage_Call
- func (_c *Queue_DeleteMessage_Call) Run(run func(ctx context.Context, receiptHandle string)) *Queue_DeleteMessage_Call
- func (_c *Queue_DeleteMessage_Call) RunAndReturn(run func(context.Context, string) error) *Queue_DeleteMessage_Call
- type Queue_Expecter
- func (_e *Queue_Expecter) DeleteMessage(ctx interface{}, receiptHandle interface{}) *Queue_DeleteMessage_Call
- func (_e *Queue_Expecter) DeleteMessageBatch(ctx interface{}, receiptHandles interface{}) *Queue_DeleteMessageBatch_Call
- func (_e *Queue_Expecter) GetArn() *Queue_GetArn_Call
- func (_e *Queue_Expecter) GetName() *Queue_GetName_Call
- func (_e *Queue_Expecter) GetUrl() *Queue_GetUrl_Call
- func (_e *Queue_Expecter) Receive(ctx interface{}, maxNumberOfMessages interface{}, waitTime interface{}) *Queue_Receive_Call
- func (_e *Queue_Expecter) Send(ctx interface{}, msg interface{}) *Queue_Send_Call
- func (_e *Queue_Expecter) SendBatch(ctx interface{}, messages interface{}) *Queue_SendBatch_Call
- type Queue_GetArn_Call
- type Queue_GetName_Call
- type Queue_GetUrl_Call
- type Queue_Receive_Call
- func (_c *Queue_Receive_Call) Return(_a0 []types.Message, _a1 error) *Queue_Receive_Call
- func (_c *Queue_Receive_Call) Run(run func(ctx context.Context, maxNumberOfMessages int32, waitTime int32)) *Queue_Receive_Call
- func (_c *Queue_Receive_Call) RunAndReturn(run func(context.Context, int32, int32) ([]types.Message, error)) *Queue_Receive_Call
- type Queue_SendBatch_Call
- func (_c *Queue_SendBatch_Call) Return(_a0 error) *Queue_SendBatch_Call
- func (_c *Queue_SendBatch_Call) Run(run func(ctx context.Context, messages []*sqs.Message)) *Queue_SendBatch_Call
- func (_c *Queue_SendBatch_Call) RunAndReturn(run func(context.Context, []*sqs.Message) error) *Queue_SendBatch_Call
- type Queue_Send_Call
- type Service
- func (_m *Service) CreateQueue(ctx context.Context, settings *sqs.Settings) (*sqs.Properties, error)
- func (_m *Service) EXPECT() *Service_Expecter
- func (_m *Service) GetArn(ctx context.Context, url string) (string, error)
- func (_m *Service) GetPropertiesByArn(ctx context.Context, arn string) (*sqs.Properties, error)
- func (_m *Service) GetPropertiesByName(ctx context.Context, name string) (*sqs.Properties, error)
- func (_m *Service) GetUrl(ctx context.Context, name string) (string, error)
- func (_m *Service) Purge(ctx context.Context, url string) error
- func (_m *Service) QueueExists(ctx context.Context, name string) (bool, error)
- type Service_CreateQueue_Call
- func (_c *Service_CreateQueue_Call) Return(_a0 *sqs.Properties, _a1 error) *Service_CreateQueue_Call
- func (_c *Service_CreateQueue_Call) Run(run func(ctx context.Context, settings *sqs.Settings)) *Service_CreateQueue_Call
- func (_c *Service_CreateQueue_Call) RunAndReturn(run func(context.Context, *sqs.Settings) (*sqs.Properties, error)) *Service_CreateQueue_Call
- type Service_Expecter
- func (_e *Service_Expecter) CreateQueue(ctx interface{}, settings interface{}) *Service_CreateQueue_Call
- func (_e *Service_Expecter) GetArn(ctx interface{}, url interface{}) *Service_GetArn_Call
- func (_e *Service_Expecter) GetPropertiesByArn(ctx interface{}, arn interface{}) *Service_GetPropertiesByArn_Call
- func (_e *Service_Expecter) GetPropertiesByName(ctx interface{}, name interface{}) *Service_GetPropertiesByName_Call
- func (_e *Service_Expecter) GetUrl(ctx interface{}, name interface{}) *Service_GetUrl_Call
- func (_e *Service_Expecter) Purge(ctx interface{}, url interface{}) *Service_Purge_Call
- func (_e *Service_Expecter) QueueExists(ctx interface{}, name interface{}) *Service_QueueExists_Call
- type Service_GetArn_Call
- type Service_GetPropertiesByArn_Call
- func (_c *Service_GetPropertiesByArn_Call) Return(_a0 *sqs.Properties, _a1 error) *Service_GetPropertiesByArn_Call
- func (_c *Service_GetPropertiesByArn_Call) Run(run func(ctx context.Context, arn string)) *Service_GetPropertiesByArn_Call
- func (_c *Service_GetPropertiesByArn_Call) RunAndReturn(run func(context.Context, string) (*sqs.Properties, error)) *Service_GetPropertiesByArn_Call
- type Service_GetPropertiesByName_Call
- func (_c *Service_GetPropertiesByName_Call) Return(_a0 *sqs.Properties, _a1 error) *Service_GetPropertiesByName_Call
- func (_c *Service_GetPropertiesByName_Call) Run(run func(ctx context.Context, name string)) *Service_GetPropertiesByName_Call
- func (_c *Service_GetPropertiesByName_Call) RunAndReturn(run func(context.Context, string) (*sqs.Properties, error)) *Service_GetPropertiesByName_Call
- type Service_GetUrl_Call
- type Service_Purge_Call
- type Service_QueueExists_Call
- func (_c *Service_QueueExists_Call) Return(_a0 bool, _a1 error) *Service_QueueExists_Call
- func (_c *Service_QueueExists_Call) Run(run func(ctx context.Context, name string)) *Service_QueueExists_Call
- func (_c *Service_QueueExists_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *Service_QueueExists_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
Client is an autogenerated mock type for the Client type
func NewClient ¶
func NewClient(t mockConstructorTestingTNewClient) *Client
NewClient creates a new instance of Client. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Client) CreateQueue ¶
func (_m *Client) CreateQueue(ctx context.Context, params *sqs.CreateQueueInput, optFns ...func(*sqs.Options)) (*sqs.CreateQueueOutput, error)
CreateQueue provides a mock function with given fields: ctx, params, optFns
func (*Client) DeleteMessage ¶
func (_m *Client) DeleteMessage(ctx context.Context, params *sqs.DeleteMessageInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)
DeleteMessage provides a mock function with given fields: ctx, params, optFns
func (*Client) DeleteMessageBatch ¶
func (_m *Client) DeleteMessageBatch(ctx context.Context, params *sqs.DeleteMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.DeleteMessageBatchOutput, error)
DeleteMessageBatch provides a mock function with given fields: ctx, params, optFns
func (*Client) EXPECT ¶
func (_m *Client) EXPECT() *Client_Expecter
func (*Client) GetQueueAttributes ¶
func (_m *Client) GetQueueAttributes(ctx context.Context, params *sqs.GetQueueAttributesInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueAttributesOutput, error)
GetQueueAttributes provides a mock function with given fields: ctx, params, optFns
func (*Client) GetQueueUrl ¶
func (_m *Client) GetQueueUrl(ctx context.Context, params *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)
GetQueueUrl provides a mock function with given fields: ctx, params, optFns
func (*Client) PurgeQueue ¶
func (_m *Client) PurgeQueue(ctx context.Context, params *sqs.PurgeQueueInput, optFns ...func(*sqs.Options)) (*sqs.PurgeQueueOutput, error)
PurgeQueue provides a mock function with given fields: ctx, params, optFns
func (*Client) ReceiveMessage ¶
func (_m *Client) ReceiveMessage(ctx context.Context, params *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)
ReceiveMessage provides a mock function with given fields: ctx, params, optFns
func (*Client) SendMessage ¶
func (_m *Client) SendMessage(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)
SendMessage provides a mock function with given fields: ctx, params, optFns
func (*Client) SendMessageBatch ¶
func (_m *Client) SendMessageBatch(ctx context.Context, params *sqs.SendMessageBatchInput, optFns ...func(*sqs.Options)) (*sqs.SendMessageBatchOutput, error)
SendMessageBatch provides a mock function with given fields: ctx, params, optFns
func (*Client) SetQueueAttributes ¶
func (_m *Client) SetQueueAttributes(ctx context.Context, params *sqs.SetQueueAttributesInput, optFns ...func(*sqs.Options)) (*sqs.SetQueueAttributesOutput, error)
SetQueueAttributes provides a mock function with given fields: ctx, params, optFns
type Client_CreateQueue_Call ¶
Client_CreateQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateQueue'
func (*Client_CreateQueue_Call) Return ¶
func (_c *Client_CreateQueue_Call) Return(_a0 *sqs.CreateQueueOutput, _a1 error) *Client_CreateQueue_Call
func (*Client_CreateQueue_Call) Run ¶
func (_c *Client_CreateQueue_Call) Run(run func(ctx context.Context, params *sqs.CreateQueueInput, optFns ...func(*sqs.Options))) *Client_CreateQueue_Call
func (*Client_CreateQueue_Call) RunAndReturn ¶
func (_c *Client_CreateQueue_Call) RunAndReturn(run func(context.Context, *sqs.CreateQueueInput, ...func(*sqs.Options)) (*sqs.CreateQueueOutput, error)) *Client_CreateQueue_Call
type Client_DeleteMessageBatch_Call ¶
Client_DeleteMessageBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteMessageBatch'
func (*Client_DeleteMessageBatch_Call) Return ¶
func (_c *Client_DeleteMessageBatch_Call) Return(_a0 *sqs.DeleteMessageBatchOutput, _a1 error) *Client_DeleteMessageBatch_Call
func (*Client_DeleteMessageBatch_Call) Run ¶
func (_c *Client_DeleteMessageBatch_Call) Run(run func(ctx context.Context, params *sqs.DeleteMessageBatchInput, optFns ...func(*sqs.Options))) *Client_DeleteMessageBatch_Call
func (*Client_DeleteMessageBatch_Call) RunAndReturn ¶
func (_c *Client_DeleteMessageBatch_Call) RunAndReturn(run func(context.Context, *sqs.DeleteMessageBatchInput, ...func(*sqs.Options)) (*sqs.DeleteMessageBatchOutput, error)) *Client_DeleteMessageBatch_Call
type Client_DeleteMessage_Call ¶
Client_DeleteMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteMessage'
func (*Client_DeleteMessage_Call) Return ¶
func (_c *Client_DeleteMessage_Call) Return(_a0 *sqs.DeleteMessageOutput, _a1 error) *Client_DeleteMessage_Call
func (*Client_DeleteMessage_Call) Run ¶
func (_c *Client_DeleteMessage_Call) Run(run func(ctx context.Context, params *sqs.DeleteMessageInput, optFns ...func(*sqs.Options))) *Client_DeleteMessage_Call
func (*Client_DeleteMessage_Call) RunAndReturn ¶
func (_c *Client_DeleteMessage_Call) RunAndReturn(run func(context.Context, *sqs.DeleteMessageInput, ...func(*sqs.Options)) (*sqs.DeleteMessageOutput, error)) *Client_DeleteMessage_Call
type Client_Expecter ¶
type Client_Expecter struct {
// contains filtered or unexported fields
}
func (*Client_Expecter) CreateQueue ¶
func (_e *Client_Expecter) CreateQueue(ctx interface{}, params interface{}, optFns ...interface{}) *Client_CreateQueue_Call
CreateQueue is a helper method to define mock.On call
- ctx context.Context
- params *sqs.CreateQueueInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) DeleteMessage ¶
func (_e *Client_Expecter) DeleteMessage(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DeleteMessage_Call
DeleteMessage is a helper method to define mock.On call
- ctx context.Context
- params *sqs.DeleteMessageInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) DeleteMessageBatch ¶
func (_e *Client_Expecter) DeleteMessageBatch(ctx interface{}, params interface{}, optFns ...interface{}) *Client_DeleteMessageBatch_Call
DeleteMessageBatch is a helper method to define mock.On call
- ctx context.Context
- params *sqs.DeleteMessageBatchInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) GetQueueAttributes ¶
func (_e *Client_Expecter) GetQueueAttributes(ctx interface{}, params interface{}, optFns ...interface{}) *Client_GetQueueAttributes_Call
GetQueueAttributes is a helper method to define mock.On call
- ctx context.Context
- params *sqs.GetQueueAttributesInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) GetQueueUrl ¶
func (_e *Client_Expecter) GetQueueUrl(ctx interface{}, params interface{}, optFns ...interface{}) *Client_GetQueueUrl_Call
GetQueueUrl is a helper method to define mock.On call
- ctx context.Context
- params *sqs.GetQueueUrlInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) PurgeQueue ¶
func (_e *Client_Expecter) PurgeQueue(ctx interface{}, params interface{}, optFns ...interface{}) *Client_PurgeQueue_Call
PurgeQueue is a helper method to define mock.On call
- ctx context.Context
- params *sqs.PurgeQueueInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) ReceiveMessage ¶
func (_e *Client_Expecter) ReceiveMessage(ctx interface{}, params interface{}, optFns ...interface{}) *Client_ReceiveMessage_Call
ReceiveMessage is a helper method to define mock.On call
- ctx context.Context
- params *sqs.ReceiveMessageInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) SendMessage ¶
func (_e *Client_Expecter) SendMessage(ctx interface{}, params interface{}, optFns ...interface{}) *Client_SendMessage_Call
SendMessage is a helper method to define mock.On call
- ctx context.Context
- params *sqs.SendMessageInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) SendMessageBatch ¶
func (_e *Client_Expecter) SendMessageBatch(ctx interface{}, params interface{}, optFns ...interface{}) *Client_SendMessageBatch_Call
SendMessageBatch is a helper method to define mock.On call
- ctx context.Context
- params *sqs.SendMessageBatchInput
- optFns ...func(*sqs.Options)
func (*Client_Expecter) SetQueueAttributes ¶
func (_e *Client_Expecter) SetQueueAttributes(ctx interface{}, params interface{}, optFns ...interface{}) *Client_SetQueueAttributes_Call
SetQueueAttributes is a helper method to define mock.On call
- ctx context.Context
- params *sqs.SetQueueAttributesInput
- optFns ...func(*sqs.Options)
type Client_GetQueueAttributes_Call ¶
Client_GetQueueAttributes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetQueueAttributes'
func (*Client_GetQueueAttributes_Call) Return ¶
func (_c *Client_GetQueueAttributes_Call) Return(_a0 *sqs.GetQueueAttributesOutput, _a1 error) *Client_GetQueueAttributes_Call
func (*Client_GetQueueAttributes_Call) Run ¶
func (_c *Client_GetQueueAttributes_Call) Run(run func(ctx context.Context, params *sqs.GetQueueAttributesInput, optFns ...func(*sqs.Options))) *Client_GetQueueAttributes_Call
func (*Client_GetQueueAttributes_Call) RunAndReturn ¶
func (_c *Client_GetQueueAttributes_Call) RunAndReturn(run func(context.Context, *sqs.GetQueueAttributesInput, ...func(*sqs.Options)) (*sqs.GetQueueAttributesOutput, error)) *Client_GetQueueAttributes_Call
type Client_GetQueueUrl_Call ¶
Client_GetQueueUrl_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetQueueUrl'
func (*Client_GetQueueUrl_Call) Return ¶
func (_c *Client_GetQueueUrl_Call) Return(_a0 *sqs.GetQueueUrlOutput, _a1 error) *Client_GetQueueUrl_Call
func (*Client_GetQueueUrl_Call) Run ¶
func (_c *Client_GetQueueUrl_Call) Run(run func(ctx context.Context, params *sqs.GetQueueUrlInput, optFns ...func(*sqs.Options))) *Client_GetQueueUrl_Call
func (*Client_GetQueueUrl_Call) RunAndReturn ¶
func (_c *Client_GetQueueUrl_Call) RunAndReturn(run func(context.Context, *sqs.GetQueueUrlInput, ...func(*sqs.Options)) (*sqs.GetQueueUrlOutput, error)) *Client_GetQueueUrl_Call
type Client_PurgeQueue_Call ¶
Client_PurgeQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PurgeQueue'
func (*Client_PurgeQueue_Call) Return ¶
func (_c *Client_PurgeQueue_Call) Return(_a0 *sqs.PurgeQueueOutput, _a1 error) *Client_PurgeQueue_Call
func (*Client_PurgeQueue_Call) Run ¶
func (_c *Client_PurgeQueue_Call) Run(run func(ctx context.Context, params *sqs.PurgeQueueInput, optFns ...func(*sqs.Options))) *Client_PurgeQueue_Call
func (*Client_PurgeQueue_Call) RunAndReturn ¶
func (_c *Client_PurgeQueue_Call) RunAndReturn(run func(context.Context, *sqs.PurgeQueueInput, ...func(*sqs.Options)) (*sqs.PurgeQueueOutput, error)) *Client_PurgeQueue_Call
type Client_ReceiveMessage_Call ¶
Client_ReceiveMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ReceiveMessage'
func (*Client_ReceiveMessage_Call) Return ¶
func (_c *Client_ReceiveMessage_Call) Return(_a0 *sqs.ReceiveMessageOutput, _a1 error) *Client_ReceiveMessage_Call
func (*Client_ReceiveMessage_Call) Run ¶
func (_c *Client_ReceiveMessage_Call) Run(run func(ctx context.Context, params *sqs.ReceiveMessageInput, optFns ...func(*sqs.Options))) *Client_ReceiveMessage_Call
func (*Client_ReceiveMessage_Call) RunAndReturn ¶
func (_c *Client_ReceiveMessage_Call) RunAndReturn(run func(context.Context, *sqs.ReceiveMessageInput, ...func(*sqs.Options)) (*sqs.ReceiveMessageOutput, error)) *Client_ReceiveMessage_Call
type Client_SendMessageBatch_Call ¶
Client_SendMessageBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMessageBatch'
func (*Client_SendMessageBatch_Call) Return ¶
func (_c *Client_SendMessageBatch_Call) Return(_a0 *sqs.SendMessageBatchOutput, _a1 error) *Client_SendMessageBatch_Call
func (*Client_SendMessageBatch_Call) Run ¶
func (_c *Client_SendMessageBatch_Call) Run(run func(ctx context.Context, params *sqs.SendMessageBatchInput, optFns ...func(*sqs.Options))) *Client_SendMessageBatch_Call
func (*Client_SendMessageBatch_Call) RunAndReturn ¶
func (_c *Client_SendMessageBatch_Call) RunAndReturn(run func(context.Context, *sqs.SendMessageBatchInput, ...func(*sqs.Options)) (*sqs.SendMessageBatchOutput, error)) *Client_SendMessageBatch_Call
type Client_SendMessage_Call ¶
Client_SendMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendMessage'
func (*Client_SendMessage_Call) Return ¶
func (_c *Client_SendMessage_Call) Return(_a0 *sqs.SendMessageOutput, _a1 error) *Client_SendMessage_Call
func (*Client_SendMessage_Call) Run ¶
func (_c *Client_SendMessage_Call) Run(run func(ctx context.Context, params *sqs.SendMessageInput, optFns ...func(*sqs.Options))) *Client_SendMessage_Call
func (*Client_SendMessage_Call) RunAndReturn ¶
func (_c *Client_SendMessage_Call) RunAndReturn(run func(context.Context, *sqs.SendMessageInput, ...func(*sqs.Options)) (*sqs.SendMessageOutput, error)) *Client_SendMessage_Call
type Client_SetQueueAttributes_Call ¶
Client_SetQueueAttributes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetQueueAttributes'
func (*Client_SetQueueAttributes_Call) Return ¶
func (_c *Client_SetQueueAttributes_Call) Return(_a0 *sqs.SetQueueAttributesOutput, _a1 error) *Client_SetQueueAttributes_Call
func (*Client_SetQueueAttributes_Call) Run ¶
func (_c *Client_SetQueueAttributes_Call) Run(run func(ctx context.Context, params *sqs.SetQueueAttributesInput, optFns ...func(*sqs.Options))) *Client_SetQueueAttributes_Call
func (*Client_SetQueueAttributes_Call) RunAndReturn ¶
func (_c *Client_SetQueueAttributes_Call) RunAndReturn(run func(context.Context, *sqs.SetQueueAttributesInput, ...func(*sqs.Options)) (*sqs.SetQueueAttributesOutput, error)) *Client_SetQueueAttributes_Call
type Queue ¶
Queue is an autogenerated mock type for the Queue type
func NewQueue ¶
func NewQueue(t mockConstructorTestingTNewQueue) *Queue
NewQueue creates a new instance of Queue. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Queue) DeleteMessage ¶
DeleteMessage provides a mock function with given fields: ctx, receiptHandle
func (*Queue) DeleteMessageBatch ¶
DeleteMessageBatch provides a mock function with given fields: ctx, receiptHandles
func (*Queue) EXPECT ¶
func (_m *Queue) EXPECT() *Queue_Expecter
func (*Queue) Receive ¶
func (_m *Queue) Receive(ctx context.Context, maxNumberOfMessages int32, waitTime int32) ([]types.Message, error)
Receive provides a mock function with given fields: ctx, maxNumberOfMessages, waitTime
type Queue_DeleteMessageBatch_Call ¶
Queue_DeleteMessageBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteMessageBatch'
func (*Queue_DeleteMessageBatch_Call) Return ¶
func (_c *Queue_DeleteMessageBatch_Call) Return(_a0 error) *Queue_DeleteMessageBatch_Call
func (*Queue_DeleteMessageBatch_Call) Run ¶
func (_c *Queue_DeleteMessageBatch_Call) Run(run func(ctx context.Context, receiptHandles []string)) *Queue_DeleteMessageBatch_Call
func (*Queue_DeleteMessageBatch_Call) RunAndReturn ¶
func (_c *Queue_DeleteMessageBatch_Call) RunAndReturn(run func(context.Context, []string) error) *Queue_DeleteMessageBatch_Call
type Queue_DeleteMessage_Call ¶
Queue_DeleteMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteMessage'
func (*Queue_DeleteMessage_Call) Return ¶
func (_c *Queue_DeleteMessage_Call) Return(_a0 error) *Queue_DeleteMessage_Call
func (*Queue_DeleteMessage_Call) Run ¶
func (_c *Queue_DeleteMessage_Call) Run(run func(ctx context.Context, receiptHandle string)) *Queue_DeleteMessage_Call
func (*Queue_DeleteMessage_Call) RunAndReturn ¶
func (_c *Queue_DeleteMessage_Call) RunAndReturn(run func(context.Context, string) error) *Queue_DeleteMessage_Call
type Queue_Expecter ¶
type Queue_Expecter struct {
// contains filtered or unexported fields
}
func (*Queue_Expecter) DeleteMessage ¶
func (_e *Queue_Expecter) DeleteMessage(ctx interface{}, receiptHandle interface{}) *Queue_DeleteMessage_Call
DeleteMessage is a helper method to define mock.On call
- ctx context.Context
- receiptHandle string
func (*Queue_Expecter) DeleteMessageBatch ¶
func (_e *Queue_Expecter) DeleteMessageBatch(ctx interface{}, receiptHandles interface{}) *Queue_DeleteMessageBatch_Call
DeleteMessageBatch is a helper method to define mock.On call
- ctx context.Context
- receiptHandles []string
func (*Queue_Expecter) GetArn ¶
func (_e *Queue_Expecter) GetArn() *Queue_GetArn_Call
GetArn is a helper method to define mock.On call
func (*Queue_Expecter) GetName ¶
func (_e *Queue_Expecter) GetName() *Queue_GetName_Call
GetName is a helper method to define mock.On call
func (*Queue_Expecter) GetUrl ¶
func (_e *Queue_Expecter) GetUrl() *Queue_GetUrl_Call
GetUrl is a helper method to define mock.On call
func (*Queue_Expecter) Receive ¶
func (_e *Queue_Expecter) Receive(ctx interface{}, maxNumberOfMessages interface{}, waitTime interface{}) *Queue_Receive_Call
Receive is a helper method to define mock.On call
- ctx context.Context
- maxNumberOfMessages int32
- waitTime int32
func (*Queue_Expecter) Send ¶
func (_e *Queue_Expecter) Send(ctx interface{}, msg interface{}) *Queue_Send_Call
Send is a helper method to define mock.On call
- ctx context.Context
- msg *sqs.Message
func (*Queue_Expecter) SendBatch ¶
func (_e *Queue_Expecter) SendBatch(ctx interface{}, messages interface{}) *Queue_SendBatch_Call
SendBatch is a helper method to define mock.On call
- ctx context.Context
- messages []*sqs.Message
type Queue_GetArn_Call ¶
Queue_GetArn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetArn'
func (*Queue_GetArn_Call) Return ¶
func (_c *Queue_GetArn_Call) Return(_a0 string) *Queue_GetArn_Call
func (*Queue_GetArn_Call) Run ¶
func (_c *Queue_GetArn_Call) Run(run func()) *Queue_GetArn_Call
func (*Queue_GetArn_Call) RunAndReturn ¶
func (_c *Queue_GetArn_Call) RunAndReturn(run func() string) *Queue_GetArn_Call
type Queue_GetName_Call ¶
Queue_GetName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetName'
func (*Queue_GetName_Call) Return ¶
func (_c *Queue_GetName_Call) Return(_a0 string) *Queue_GetName_Call
func (*Queue_GetName_Call) Run ¶
func (_c *Queue_GetName_Call) Run(run func()) *Queue_GetName_Call
func (*Queue_GetName_Call) RunAndReturn ¶
func (_c *Queue_GetName_Call) RunAndReturn(run func() string) *Queue_GetName_Call
type Queue_GetUrl_Call ¶
Queue_GetUrl_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUrl'
func (*Queue_GetUrl_Call) Return ¶
func (_c *Queue_GetUrl_Call) Return(_a0 string) *Queue_GetUrl_Call
func (*Queue_GetUrl_Call) Run ¶
func (_c *Queue_GetUrl_Call) Run(run func()) *Queue_GetUrl_Call
func (*Queue_GetUrl_Call) RunAndReturn ¶
func (_c *Queue_GetUrl_Call) RunAndReturn(run func() string) *Queue_GetUrl_Call
type Queue_Receive_Call ¶
Queue_Receive_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Receive'
func (*Queue_Receive_Call) Return ¶
func (_c *Queue_Receive_Call) Return(_a0 []types.Message, _a1 error) *Queue_Receive_Call
func (*Queue_Receive_Call) Run ¶
func (_c *Queue_Receive_Call) Run(run func(ctx context.Context, maxNumberOfMessages int32, waitTime int32)) *Queue_Receive_Call
func (*Queue_Receive_Call) RunAndReturn ¶
func (_c *Queue_Receive_Call) RunAndReturn(run func(context.Context, int32, int32) ([]types.Message, error)) *Queue_Receive_Call
type Queue_SendBatch_Call ¶
Queue_SendBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendBatch'
func (*Queue_SendBatch_Call) Return ¶
func (_c *Queue_SendBatch_Call) Return(_a0 error) *Queue_SendBatch_Call
func (*Queue_SendBatch_Call) Run ¶
func (_c *Queue_SendBatch_Call) Run(run func(ctx context.Context, messages []*sqs.Message)) *Queue_SendBatch_Call
func (*Queue_SendBatch_Call) RunAndReturn ¶
func (_c *Queue_SendBatch_Call) RunAndReturn(run func(context.Context, []*sqs.Message) error) *Queue_SendBatch_Call
type Queue_Send_Call ¶
Queue_Send_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Send'
func (*Queue_Send_Call) Return ¶
func (_c *Queue_Send_Call) Return(_a0 error) *Queue_Send_Call
func (*Queue_Send_Call) Run ¶
func (_c *Queue_Send_Call) Run(run func(ctx context.Context, msg *sqs.Message)) *Queue_Send_Call
func (*Queue_Send_Call) RunAndReturn ¶
func (_c *Queue_Send_Call) RunAndReturn(run func(context.Context, *sqs.Message) error) *Queue_Send_Call
type Service ¶
Service is an autogenerated mock type for the Service type
func NewService ¶
func NewService(t mockConstructorTestingTNewService) *Service
NewService creates a new instance of Service. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*Service) CreateQueue ¶
func (_m *Service) CreateQueue(ctx context.Context, settings *sqs.Settings) (*sqs.Properties, error)
CreateQueue provides a mock function with given fields: ctx, settings
func (*Service) EXPECT ¶
func (_m *Service) EXPECT() *Service_Expecter
func (*Service) GetPropertiesByArn ¶
GetPropertiesByArn provides a mock function with given fields: ctx, arn
func (*Service) GetPropertiesByName ¶
GetPropertiesByName provides a mock function with given fields: ctx, name
type Service_CreateQueue_Call ¶
Service_CreateQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateQueue'
func (*Service_CreateQueue_Call) Return ¶
func (_c *Service_CreateQueue_Call) Return(_a0 *sqs.Properties, _a1 error) *Service_CreateQueue_Call
func (*Service_CreateQueue_Call) Run ¶
func (_c *Service_CreateQueue_Call) Run(run func(ctx context.Context, settings *sqs.Settings)) *Service_CreateQueue_Call
func (*Service_CreateQueue_Call) RunAndReturn ¶
func (_c *Service_CreateQueue_Call) RunAndReturn(run func(context.Context, *sqs.Settings) (*sqs.Properties, error)) *Service_CreateQueue_Call
type Service_Expecter ¶
type Service_Expecter struct {
// contains filtered or unexported fields
}
func (*Service_Expecter) CreateQueue ¶
func (_e *Service_Expecter) CreateQueue(ctx interface{}, settings interface{}) *Service_CreateQueue_Call
CreateQueue is a helper method to define mock.On call
- ctx context.Context
- settings *sqs.Settings
func (*Service_Expecter) GetArn ¶
func (_e *Service_Expecter) GetArn(ctx interface{}, url interface{}) *Service_GetArn_Call
GetArn is a helper method to define mock.On call
- ctx context.Context
- url string
func (*Service_Expecter) GetPropertiesByArn ¶
func (_e *Service_Expecter) GetPropertiesByArn(ctx interface{}, arn interface{}) *Service_GetPropertiesByArn_Call
GetPropertiesByArn is a helper method to define mock.On call
- ctx context.Context
- arn string
func (*Service_Expecter) GetPropertiesByName ¶
func (_e *Service_Expecter) GetPropertiesByName(ctx interface{}, name interface{}) *Service_GetPropertiesByName_Call
GetPropertiesByName is a helper method to define mock.On call
- ctx context.Context
- name string
func (*Service_Expecter) GetUrl ¶
func (_e *Service_Expecter) GetUrl(ctx interface{}, name interface{}) *Service_GetUrl_Call
GetUrl is a helper method to define mock.On call
- ctx context.Context
- name string
func (*Service_Expecter) Purge ¶
func (_e *Service_Expecter) Purge(ctx interface{}, url interface{}) *Service_Purge_Call
Purge is a helper method to define mock.On call
- ctx context.Context
- url string
func (*Service_Expecter) QueueExists ¶
func (_e *Service_Expecter) QueueExists(ctx interface{}, name interface{}) *Service_QueueExists_Call
QueueExists is a helper method to define mock.On call
- ctx context.Context
- name string
type Service_GetArn_Call ¶
Service_GetArn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetArn'
func (*Service_GetArn_Call) Return ¶
func (_c *Service_GetArn_Call) Return(_a0 string, _a1 error) *Service_GetArn_Call
func (*Service_GetArn_Call) Run ¶
func (_c *Service_GetArn_Call) Run(run func(ctx context.Context, url string)) *Service_GetArn_Call
func (*Service_GetArn_Call) RunAndReturn ¶
func (_c *Service_GetArn_Call) RunAndReturn(run func(context.Context, string) (string, error)) *Service_GetArn_Call
type Service_GetPropertiesByArn_Call ¶
Service_GetPropertiesByArn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPropertiesByArn'
func (*Service_GetPropertiesByArn_Call) Return ¶
func (_c *Service_GetPropertiesByArn_Call) Return(_a0 *sqs.Properties, _a1 error) *Service_GetPropertiesByArn_Call
func (*Service_GetPropertiesByArn_Call) Run ¶
func (_c *Service_GetPropertiesByArn_Call) Run(run func(ctx context.Context, arn string)) *Service_GetPropertiesByArn_Call
func (*Service_GetPropertiesByArn_Call) RunAndReturn ¶
func (_c *Service_GetPropertiesByArn_Call) RunAndReturn(run func(context.Context, string) (*sqs.Properties, error)) *Service_GetPropertiesByArn_Call
type Service_GetPropertiesByName_Call ¶
Service_GetPropertiesByName_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPropertiesByName'
func (*Service_GetPropertiesByName_Call) Return ¶
func (_c *Service_GetPropertiesByName_Call) Return(_a0 *sqs.Properties, _a1 error) *Service_GetPropertiesByName_Call
func (*Service_GetPropertiesByName_Call) Run ¶
func (_c *Service_GetPropertiesByName_Call) Run(run func(ctx context.Context, name string)) *Service_GetPropertiesByName_Call
func (*Service_GetPropertiesByName_Call) RunAndReturn ¶
func (_c *Service_GetPropertiesByName_Call) RunAndReturn(run func(context.Context, string) (*sqs.Properties, error)) *Service_GetPropertiesByName_Call
type Service_GetUrl_Call ¶
Service_GetUrl_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUrl'
func (*Service_GetUrl_Call) Return ¶
func (_c *Service_GetUrl_Call) Return(_a0 string, _a1 error) *Service_GetUrl_Call
func (*Service_GetUrl_Call) Run ¶
func (_c *Service_GetUrl_Call) Run(run func(ctx context.Context, name string)) *Service_GetUrl_Call
func (*Service_GetUrl_Call) RunAndReturn ¶
func (_c *Service_GetUrl_Call) RunAndReturn(run func(context.Context, string) (string, error)) *Service_GetUrl_Call
type Service_Purge_Call ¶
Service_Purge_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Purge'
func (*Service_Purge_Call) Return ¶
func (_c *Service_Purge_Call) Return(_a0 error) *Service_Purge_Call
func (*Service_Purge_Call) Run ¶
func (_c *Service_Purge_Call) Run(run func(ctx context.Context, url string)) *Service_Purge_Call
func (*Service_Purge_Call) RunAndReturn ¶
func (_c *Service_Purge_Call) RunAndReturn(run func(context.Context, string) error) *Service_Purge_Call
type Service_QueueExists_Call ¶
Service_QueueExists_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'QueueExists'
func (*Service_QueueExists_Call) Return ¶
func (_c *Service_QueueExists_Call) Return(_a0 bool, _a1 error) *Service_QueueExists_Call
func (*Service_QueueExists_Call) Run ¶
func (_c *Service_QueueExists_Call) Run(run func(ctx context.Context, name string)) *Service_QueueExists_Call
func (*Service_QueueExists_Call) RunAndReturn ¶
func (_c *Service_QueueExists_Call) RunAndReturn(run func(context.Context, string) (bool, error)) *Service_QueueExists_Call