Documentation ¶
Index ¶
- type Client
- func (_m *Client) CreateTopic(ctx context.Context, params *sns.CreateTopicInput, ...) (*sns.CreateTopicOutput, error)
- func (_m *Client) EXPECT() *Client_Expecter
- func (_m *Client) GetSubscriptionAttributes(ctx context.Context, params *sns.GetSubscriptionAttributesInput, ...) (*sns.GetSubscriptionAttributesOutput, error)
- func (_m *Client) ListSubscriptionsByTopic(ctx context.Context, params *sns.ListSubscriptionsByTopicInput, ...) (*sns.ListSubscriptionsByTopicOutput, error)
- func (_m *Client) Publish(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)
- func (_m *Client) PublishBatch(ctx context.Context, input *sns.PublishBatchInput, ...) (*sns.PublishBatchOutput, error)
- func (_m *Client) Subscribe(ctx context.Context, params *sns.SubscribeInput, optFns ...func(*sns.Options)) (*sns.SubscribeOutput, error)
- func (_m *Client) Unsubscribe(ctx context.Context, params *sns.UnsubscribeInput, ...) (*sns.UnsubscribeOutput, error)
- type Client_CreateTopic_Call
- func (_c *Client_CreateTopic_Call) Return(_a0 *sns.CreateTopicOutput, _a1 error) *Client_CreateTopic_Call
- func (_c *Client_CreateTopic_Call) Run(run func(ctx context.Context, params *sns.CreateTopicInput, ...)) *Client_CreateTopic_Call
- func (_c *Client_CreateTopic_Call) RunAndReturn(...) *Client_CreateTopic_Call
- type Client_Expecter
- func (_e *Client_Expecter) CreateTopic(ctx interface{}, params interface{}, optFns ...interface{}) *Client_CreateTopic_Call
- func (_e *Client_Expecter) GetSubscriptionAttributes(ctx interface{}, params interface{}, optFns ...interface{}) *Client_GetSubscriptionAttributes_Call
- func (_e *Client_Expecter) ListSubscriptionsByTopic(ctx interface{}, params interface{}, optFns ...interface{}) *Client_ListSubscriptionsByTopic_Call
- func (_e *Client_Expecter) Publish(ctx interface{}, params interface{}, optFns ...interface{}) *Client_Publish_Call
- func (_e *Client_Expecter) PublishBatch(ctx interface{}, input interface{}, optFns ...interface{}) *Client_PublishBatch_Call
- func (_e *Client_Expecter) Subscribe(ctx interface{}, params interface{}, optFns ...interface{}) *Client_Subscribe_Call
- func (_e *Client_Expecter) Unsubscribe(ctx interface{}, params interface{}, optFns ...interface{}) *Client_Unsubscribe_Call
- type Client_GetSubscriptionAttributes_Call
- func (_c *Client_GetSubscriptionAttributes_Call) Return(_a0 *sns.GetSubscriptionAttributesOutput, _a1 error) *Client_GetSubscriptionAttributes_Call
- func (_c *Client_GetSubscriptionAttributes_Call) Run(run func(ctx context.Context, params *sns.GetSubscriptionAttributesInput, ...)) *Client_GetSubscriptionAttributes_Call
- func (_c *Client_GetSubscriptionAttributes_Call) RunAndReturn(...) *Client_GetSubscriptionAttributes_Call
- type Client_ListSubscriptionsByTopic_Call
- func (_c *Client_ListSubscriptionsByTopic_Call) Return(_a0 *sns.ListSubscriptionsByTopicOutput, _a1 error) *Client_ListSubscriptionsByTopic_Call
- func (_c *Client_ListSubscriptionsByTopic_Call) Run(run func(ctx context.Context, params *sns.ListSubscriptionsByTopicInput, ...)) *Client_ListSubscriptionsByTopic_Call
- func (_c *Client_ListSubscriptionsByTopic_Call) RunAndReturn(...) *Client_ListSubscriptionsByTopic_Call
- type Client_PublishBatch_Call
- func (_c *Client_PublishBatch_Call) Return(_a0 *sns.PublishBatchOutput, _a1 error) *Client_PublishBatch_Call
- func (_c *Client_PublishBatch_Call) Run(run func(ctx context.Context, input *sns.PublishBatchInput, ...)) *Client_PublishBatch_Call
- func (_c *Client_PublishBatch_Call) RunAndReturn(...) *Client_PublishBatch_Call
- type Client_Publish_Call
- type Client_Subscribe_Call
- type Client_Unsubscribe_Call
- func (_c *Client_Unsubscribe_Call) Return(_a0 *sns.UnsubscribeOutput, _a1 error) *Client_Unsubscribe_Call
- func (_c *Client_Unsubscribe_Call) Run(run func(ctx context.Context, params *sns.UnsubscribeInput, ...)) *Client_Unsubscribe_Call
- func (_c *Client_Unsubscribe_Call) RunAndReturn(...) *Client_Unsubscribe_Call
- type Topic
- func (_m *Topic) EXPECT() *Topic_Expecter
- func (_m *Topic) Publish(ctx context.Context, msg string, attributes ...map[string]string) error
- func (_m *Topic) PublishBatch(ctx context.Context, messages []string, attributes []map[string]string) error
- func (_m *Topic) SubscribeSqs(ctx context.Context, queueArn string, attributes map[string]string) error
- type Topic_Expecter
- func (_e *Topic_Expecter) Publish(ctx interface{}, msg interface{}, attributes ...interface{}) *Topic_Publish_Call
- func (_e *Topic_Expecter) PublishBatch(ctx interface{}, messages interface{}, attributes interface{}) *Topic_PublishBatch_Call
- func (_e *Topic_Expecter) SubscribeSqs(ctx interface{}, queueArn interface{}, attributes interface{}) *Topic_SubscribeSqs_Call
- type Topic_PublishBatch_Call
- type Topic_Publish_Call
- func (_c *Topic_Publish_Call) Return(_a0 error) *Topic_Publish_Call
- func (_c *Topic_Publish_Call) Run(run func(ctx context.Context, msg string, attributes ...map[string]string)) *Topic_Publish_Call
- func (_c *Topic_Publish_Call) RunAndReturn(run func(context.Context, string, ...map[string]string) error) *Topic_Publish_Call
- type Topic_SubscribeSqs_Call
- func (_c *Topic_SubscribeSqs_Call) Return(_a0 error) *Topic_SubscribeSqs_Call
- func (_c *Topic_SubscribeSqs_Call) Run(run func(ctx context.Context, queueArn string, attributes map[string]string)) *Topic_SubscribeSqs_Call
- func (_c *Topic_SubscribeSqs_Call) RunAndReturn(run func(context.Context, string, map[string]string) error) *Topic_SubscribeSqs_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 ¶
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. The first argument is typically a *testing.T value.
func (*Client) CreateTopic ¶
func (_m *Client) CreateTopic(ctx context.Context, params *sns.CreateTopicInput, optFns ...func(*sns.Options)) (*sns.CreateTopicOutput, error)
CreateTopic provides a mock function with given fields: ctx, params, optFns
func (*Client) EXPECT ¶
func (_m *Client) EXPECT() *Client_Expecter
func (*Client) GetSubscriptionAttributes ¶
func (_m *Client) GetSubscriptionAttributes(ctx context.Context, params *sns.GetSubscriptionAttributesInput, optFns ...func(*sns.Options)) (*sns.GetSubscriptionAttributesOutput, error)
GetSubscriptionAttributes provides a mock function with given fields: ctx, params, optFns
func (*Client) ListSubscriptionsByTopic ¶
func (_m *Client) ListSubscriptionsByTopic(ctx context.Context, params *sns.ListSubscriptionsByTopicInput, optFns ...func(*sns.Options)) (*sns.ListSubscriptionsByTopicOutput, error)
ListSubscriptionsByTopic provides a mock function with given fields: ctx, params, optFns
func (*Client) Publish ¶
func (_m *Client) Publish(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options)) (*sns.PublishOutput, error)
Publish provides a mock function with given fields: ctx, params, optFns
func (*Client) PublishBatch ¶
func (_m *Client) PublishBatch(ctx context.Context, input *sns.PublishBatchInput, optFns ...func(*sns.Options)) (*sns.PublishBatchOutput, error)
PublishBatch provides a mock function with given fields: ctx, input, optFns
func (*Client) Subscribe ¶
func (_m *Client) Subscribe(ctx context.Context, params *sns.SubscribeInput, optFns ...func(*sns.Options)) (*sns.SubscribeOutput, error)
Subscribe provides a mock function with given fields: ctx, params, optFns
func (*Client) Unsubscribe ¶
func (_m *Client) Unsubscribe(ctx context.Context, params *sns.UnsubscribeInput, optFns ...func(*sns.Options)) (*sns.UnsubscribeOutput, error)
Unsubscribe provides a mock function with given fields: ctx, params, optFns
type Client_CreateTopic_Call ¶
Client_CreateTopic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTopic'
func (*Client_CreateTopic_Call) Return ¶
func (_c *Client_CreateTopic_Call) Return(_a0 *sns.CreateTopicOutput, _a1 error) *Client_CreateTopic_Call
func (*Client_CreateTopic_Call) Run ¶
func (_c *Client_CreateTopic_Call) Run(run func(ctx context.Context, params *sns.CreateTopicInput, optFns ...func(*sns.Options))) *Client_CreateTopic_Call
func (*Client_CreateTopic_Call) RunAndReturn ¶
func (_c *Client_CreateTopic_Call) RunAndReturn(run func(context.Context, *sns.CreateTopicInput, ...func(*sns.Options)) (*sns.CreateTopicOutput, error)) *Client_CreateTopic_Call
type Client_Expecter ¶
type Client_Expecter struct {
// contains filtered or unexported fields
}
func (*Client_Expecter) CreateTopic ¶
func (_e *Client_Expecter) CreateTopic(ctx interface{}, params interface{}, optFns ...interface{}) *Client_CreateTopic_Call
CreateTopic is a helper method to define mock.On call
- ctx context.Context
- params *sns.CreateTopicInput
- optFns ...func(*sns.Options)
func (*Client_Expecter) GetSubscriptionAttributes ¶
func (_e *Client_Expecter) GetSubscriptionAttributes(ctx interface{}, params interface{}, optFns ...interface{}) *Client_GetSubscriptionAttributes_Call
GetSubscriptionAttributes is a helper method to define mock.On call
- ctx context.Context
- params *sns.GetSubscriptionAttributesInput
- optFns ...func(*sns.Options)
func (*Client_Expecter) ListSubscriptionsByTopic ¶
func (_e *Client_Expecter) ListSubscriptionsByTopic(ctx interface{}, params interface{}, optFns ...interface{}) *Client_ListSubscriptionsByTopic_Call
ListSubscriptionsByTopic is a helper method to define mock.On call
- ctx context.Context
- params *sns.ListSubscriptionsByTopicInput
- optFns ...func(*sns.Options)
func (*Client_Expecter) Publish ¶
func (_e *Client_Expecter) Publish(ctx interface{}, params interface{}, optFns ...interface{}) *Client_Publish_Call
Publish is a helper method to define mock.On call
- ctx context.Context
- params *sns.PublishInput
- optFns ...func(*sns.Options)
func (*Client_Expecter) PublishBatch ¶
func (_e *Client_Expecter) PublishBatch(ctx interface{}, input interface{}, optFns ...interface{}) *Client_PublishBatch_Call
PublishBatch is a helper method to define mock.On call
- ctx context.Context
- input *sns.PublishBatchInput
- optFns ...func(*sns.Options)
func (*Client_Expecter) Subscribe ¶
func (_e *Client_Expecter) Subscribe(ctx interface{}, params interface{}, optFns ...interface{}) *Client_Subscribe_Call
Subscribe is a helper method to define mock.On call
- ctx context.Context
- params *sns.SubscribeInput
- optFns ...func(*sns.Options)
func (*Client_Expecter) Unsubscribe ¶
func (_e *Client_Expecter) Unsubscribe(ctx interface{}, params interface{}, optFns ...interface{}) *Client_Unsubscribe_Call
Unsubscribe is a helper method to define mock.On call
- ctx context.Context
- params *sns.UnsubscribeInput
- optFns ...func(*sns.Options)
type Client_GetSubscriptionAttributes_Call ¶
Client_GetSubscriptionAttributes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSubscriptionAttributes'
func (*Client_GetSubscriptionAttributes_Call) Return ¶
func (_c *Client_GetSubscriptionAttributes_Call) Return(_a0 *sns.GetSubscriptionAttributesOutput, _a1 error) *Client_GetSubscriptionAttributes_Call
func (*Client_GetSubscriptionAttributes_Call) Run ¶
func (_c *Client_GetSubscriptionAttributes_Call) Run(run func(ctx context.Context, params *sns.GetSubscriptionAttributesInput, optFns ...func(*sns.Options))) *Client_GetSubscriptionAttributes_Call
func (*Client_GetSubscriptionAttributes_Call) RunAndReturn ¶
func (_c *Client_GetSubscriptionAttributes_Call) RunAndReturn(run func(context.Context, *sns.GetSubscriptionAttributesInput, ...func(*sns.Options)) (*sns.GetSubscriptionAttributesOutput, error)) *Client_GetSubscriptionAttributes_Call
type Client_ListSubscriptionsByTopic_Call ¶
Client_ListSubscriptionsByTopic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListSubscriptionsByTopic'
func (*Client_ListSubscriptionsByTopic_Call) Return ¶
func (_c *Client_ListSubscriptionsByTopic_Call) Return(_a0 *sns.ListSubscriptionsByTopicOutput, _a1 error) *Client_ListSubscriptionsByTopic_Call
func (*Client_ListSubscriptionsByTopic_Call) Run ¶
func (_c *Client_ListSubscriptionsByTopic_Call) Run(run func(ctx context.Context, params *sns.ListSubscriptionsByTopicInput, optFns ...func(*sns.Options))) *Client_ListSubscriptionsByTopic_Call
func (*Client_ListSubscriptionsByTopic_Call) RunAndReturn ¶
func (_c *Client_ListSubscriptionsByTopic_Call) RunAndReturn(run func(context.Context, *sns.ListSubscriptionsByTopicInput, ...func(*sns.Options)) (*sns.ListSubscriptionsByTopicOutput, error)) *Client_ListSubscriptionsByTopic_Call
type Client_PublishBatch_Call ¶
Client_PublishBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishBatch'
func (*Client_PublishBatch_Call) Return ¶
func (_c *Client_PublishBatch_Call) Return(_a0 *sns.PublishBatchOutput, _a1 error) *Client_PublishBatch_Call
func (*Client_PublishBatch_Call) Run ¶
func (_c *Client_PublishBatch_Call) Run(run func(ctx context.Context, input *sns.PublishBatchInput, optFns ...func(*sns.Options))) *Client_PublishBatch_Call
func (*Client_PublishBatch_Call) RunAndReturn ¶
func (_c *Client_PublishBatch_Call) RunAndReturn(run func(context.Context, *sns.PublishBatchInput, ...func(*sns.Options)) (*sns.PublishBatchOutput, error)) *Client_PublishBatch_Call
type Client_Publish_Call ¶
Client_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'
func (*Client_Publish_Call) Return ¶
func (_c *Client_Publish_Call) Return(_a0 *sns.PublishOutput, _a1 error) *Client_Publish_Call
func (*Client_Publish_Call) Run ¶
func (_c *Client_Publish_Call) Run(run func(ctx context.Context, params *sns.PublishInput, optFns ...func(*sns.Options))) *Client_Publish_Call
func (*Client_Publish_Call) RunAndReturn ¶
func (_c *Client_Publish_Call) RunAndReturn(run func(context.Context, *sns.PublishInput, ...func(*sns.Options)) (*sns.PublishOutput, error)) *Client_Publish_Call
type Client_Subscribe_Call ¶
Client_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'
func (*Client_Subscribe_Call) Return ¶
func (_c *Client_Subscribe_Call) Return(_a0 *sns.SubscribeOutput, _a1 error) *Client_Subscribe_Call
func (*Client_Subscribe_Call) Run ¶
func (_c *Client_Subscribe_Call) Run(run func(ctx context.Context, params *sns.SubscribeInput, optFns ...func(*sns.Options))) *Client_Subscribe_Call
func (*Client_Subscribe_Call) RunAndReturn ¶
func (_c *Client_Subscribe_Call) RunAndReturn(run func(context.Context, *sns.SubscribeInput, ...func(*sns.Options)) (*sns.SubscribeOutput, error)) *Client_Subscribe_Call
type Client_Unsubscribe_Call ¶
Client_Unsubscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unsubscribe'
func (*Client_Unsubscribe_Call) Return ¶
func (_c *Client_Unsubscribe_Call) Return(_a0 *sns.UnsubscribeOutput, _a1 error) *Client_Unsubscribe_Call
func (*Client_Unsubscribe_Call) Run ¶
func (_c *Client_Unsubscribe_Call) Run(run func(ctx context.Context, params *sns.UnsubscribeInput, optFns ...func(*sns.Options))) *Client_Unsubscribe_Call
func (*Client_Unsubscribe_Call) RunAndReturn ¶
func (_c *Client_Unsubscribe_Call) RunAndReturn(run func(context.Context, *sns.UnsubscribeInput, ...func(*sns.Options)) (*sns.UnsubscribeOutput, error)) *Client_Unsubscribe_Call
type Topic ¶
Topic is an autogenerated mock type for the Topic type
func NewTopic ¶
NewTopic creates a new instance of Topic. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Topic) EXPECT ¶
func (_m *Topic) EXPECT() *Topic_Expecter
type Topic_Expecter ¶
type Topic_Expecter struct {
// contains filtered or unexported fields
}
func (*Topic_Expecter) Publish ¶
func (_e *Topic_Expecter) Publish(ctx interface{}, msg interface{}, attributes ...interface{}) *Topic_Publish_Call
Publish is a helper method to define mock.On call
- ctx context.Context
- msg string
- attributes ...map[string]string
func (*Topic_Expecter) PublishBatch ¶
func (_e *Topic_Expecter) PublishBatch(ctx interface{}, messages interface{}, attributes interface{}) *Topic_PublishBatch_Call
PublishBatch is a helper method to define mock.On call
- ctx context.Context
- messages []string
- attributes []map[string]string
func (*Topic_Expecter) SubscribeSqs ¶
func (_e *Topic_Expecter) SubscribeSqs(ctx interface{}, queueArn interface{}, attributes interface{}) *Topic_SubscribeSqs_Call
SubscribeSqs is a helper method to define mock.On call
- ctx context.Context
- queueArn string
- attributes map[string]string
type Topic_PublishBatch_Call ¶
Topic_PublishBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishBatch'
func (*Topic_PublishBatch_Call) Return ¶
func (_c *Topic_PublishBatch_Call) Return(_a0 error) *Topic_PublishBatch_Call
func (*Topic_PublishBatch_Call) Run ¶
func (_c *Topic_PublishBatch_Call) Run(run func(ctx context.Context, messages []string, attributes []map[string]string)) *Topic_PublishBatch_Call
func (*Topic_PublishBatch_Call) RunAndReturn ¶
func (_c *Topic_PublishBatch_Call) RunAndReturn(run func(context.Context, []string, []map[string]string) error) *Topic_PublishBatch_Call
type Topic_Publish_Call ¶
Topic_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'
func (*Topic_Publish_Call) Return ¶
func (_c *Topic_Publish_Call) Return(_a0 error) *Topic_Publish_Call
func (*Topic_Publish_Call) Run ¶
func (_c *Topic_Publish_Call) Run(run func(ctx context.Context, msg string, attributes ...map[string]string)) *Topic_Publish_Call
func (*Topic_Publish_Call) RunAndReturn ¶
func (_c *Topic_Publish_Call) RunAndReturn(run func(context.Context, string, ...map[string]string) error) *Topic_Publish_Call
type Topic_SubscribeSqs_Call ¶
Topic_SubscribeSqs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SubscribeSqs'
func (*Topic_SubscribeSqs_Call) Return ¶
func (_c *Topic_SubscribeSqs_Call) Return(_a0 error) *Topic_SubscribeSqs_Call
func (*Topic_SubscribeSqs_Call) Run ¶
func (_c *Topic_SubscribeSqs_Call) Run(run func(ctx context.Context, queueArn string, attributes map[string]string)) *Topic_SubscribeSqs_Call
func (*Topic_SubscribeSqs_Call) RunAndReturn ¶
func (_c *Topic_SubscribeSqs_Call) RunAndReturn(run func(context.Context, string, map[string]string) error) *Topic_SubscribeSqs_Call