mocks

Oct 12, 2023

Changes in this version

+ type Client struct

+ func NewClient(t mockConstructorTestingTNewClient) *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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ 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 struct

+ func (_c *Client_Publish_Call) Return(_a0 *sns.PublishOutput, _a1 error) *Client_Publish_Call

+ func (_c *Client_Publish_Call) Run(...) *Client_Publish_Call

+ func (_c *Client_Publish_Call) RunAndReturn(...) *Client_Publish_Call

+ type Client_Subscribe_Call struct

+ func (_c *Client_Subscribe_Call) Return(_a0 *sns.SubscribeOutput, _a1 error) *Client_Subscribe_Call

+ func (_c *Client_Subscribe_Call) Run(...) *Client_Subscribe_Call

+ func (_c *Client_Subscribe_Call) RunAndReturn(...) *Client_Subscribe_Call

+ type Client_Unsubscribe_Call struct

+ 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 struct

+ func NewTopic(t mockConstructorTestingTNewTopic) *Topic

+ func (_m *Topic) EXPECT() *Topic_Expecter

+ func (_m *Topic) Publish(ctx context.Context, msg string, attributes ...map[string]interface{}) error

+ func (_m *Topic) PublishBatch(ctx context.Context, messages []string, attributes []map[string]interface{}) error

+ func (_m *Topic) SubscribeSqs(ctx context.Context, queueArn string, attributes map[string]interface{}) error

+ type Topic_Expecter struct

+ 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 struct

+ func (_c *Topic_PublishBatch_Call) Return(_a0 error) *Topic_PublishBatch_Call

+ func (_c *Topic_PublishBatch_Call) Run(...) *Topic_PublishBatch_Call

+ func (_c *Topic_PublishBatch_Call) RunAndReturn(run func(context.Context, []string, []map[string]interface{}) error) *Topic_PublishBatch_Call

+ type Topic_Publish_Call struct

+ func (_c *Topic_Publish_Call) Return(_a0 error) *Topic_Publish_Call

+ func (_c *Topic_Publish_Call) Run(...) *Topic_Publish_Call

+ func (_c *Topic_Publish_Call) RunAndReturn(run func(context.Context, string, ...map[string]interface{}) error) *Topic_Publish_Call

+ type Topic_SubscribeSqs_Call struct

+ func (_c *Topic_SubscribeSqs_Call) Return(_a0 error) *Topic_SubscribeSqs_Call

+ func (_c *Topic_SubscribeSqs_Call) Run(...) *Topic_SubscribeSqs_Call

+ func (_c *Topic_SubscribeSqs_Call) RunAndReturn(run func(context.Context, string, map[string]interface{}) error) *Topic_SubscribeSqs_Call