mocks

Documentation

Index

• type IClient
  • func NewIClient(t interface{ ... }) *IClient
  • func (_m *IClient) CreateConnector(ctx context.Context, params *kafkaconnect.CreateConnectorInput, ...) (*kafkaconnect.CreateConnectorOutput, error)
  • func (_m *IClient) CreateCustomPlugin(ctx context.Context, params *kafkaconnect.CreateCustomPluginInput, ...) (*kafkaconnect.CreateCustomPluginOutput, error)
  • func (_m *IClient) CreateWorkerConfiguration(ctx context.Context, params *kafkaconnect.CreateWorkerConfigurationInput, ...) (*kafkaconnect.CreateWorkerConfigurationOutput, error)
  • func (_m *IClient) DeleteConnector(ctx context.Context, params *kafkaconnect.DeleteConnectorInput, ...) (*kafkaconnect.DeleteConnectorOutput, error)
  • func (_m *IClient) DeleteCustomPlugin(ctx context.Context, params *kafkaconnect.DeleteCustomPluginInput, ...) (*kafkaconnect.DeleteCustomPluginOutput, error)
  • func (_m *IClient) DeleteWorkerConfiguration(ctx context.Context, params *kafkaconnect.DeleteWorkerConfigurationInput, ...) (*kafkaconnect.DeleteWorkerConfigurationOutput, error)
  • func (_m *IClient) DescribeConnector(ctx context.Context, params *kafkaconnect.DescribeConnectorInput, ...) (*kafkaconnect.DescribeConnectorOutput, error)
  • func (_m *IClient) DescribeCustomPlugin(ctx context.Context, params *kafkaconnect.DescribeCustomPluginInput, ...) (*kafkaconnect.DescribeCustomPluginOutput, error)
  • func (_m *IClient) DescribeWorkerConfiguration(ctx context.Context, params *kafkaconnect.DescribeWorkerConfigurationInput, ...) (*kafkaconnect.DescribeWorkerConfigurationOutput, error)
  • func (_m *IClient) ListConnectors(ctx context.Context, params *kafkaconnect.ListConnectorsInput, ...) (*kafkaconnect.ListConnectorsOutput, error)
  • func (_m *IClient) ListCustomPlugins(ctx context.Context, params *kafkaconnect.ListCustomPluginsInput, ...) (*kafkaconnect.ListCustomPluginsOutput, error)
  • func (_m *IClient) ListTagsForResource(ctx context.Context, params *kafkaconnect.ListTagsForResourceInput, ...) (*kafkaconnect.ListTagsForResourceOutput, error)
  • func (_m *IClient) ListWorkerConfigurations(ctx context.Context, params *kafkaconnect.ListWorkerConfigurationsInput, ...) (*kafkaconnect.ListWorkerConfigurationsOutput, error)
  • func (_m *IClient) Options() kafkaconnect.Options
  • func (_m *IClient) TagResource(ctx context.Context, params *kafkaconnect.TagResourceInput, ...) (*kafkaconnect.TagResourceOutput, error)
  • func (_m *IClient) UntagResource(ctx context.Context, params *kafkaconnect.UntagResourceInput, ...) (*kafkaconnect.UntagResourceOutput, error)
  • func (_m *IClient) UpdateConnector(ctx context.Context, params *kafkaconnect.UpdateConnectorInput, ...) (*kafkaconnect.UpdateConnectorOutput, error)

Types

type IClient

type IClient struct {
	mock.Mock
}

IClient is an autogenerated mock type for the IClient type

func NewIClient

func NewIClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *IClient

NewIClient creates a new instance of IClient. 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 (*IClient) CreateConnector

func (_m *IClient) CreateConnector(ctx context.Context, params *kafkaconnect.CreateConnectorInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.CreateConnectorOutput, error)

CreateConnector provides a mock function with given fields: ctx, params, optFns

func (*IClient) CreateCustomPlugin

func (_m *IClient) CreateCustomPlugin(ctx context.Context, params *kafkaconnect.CreateCustomPluginInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.CreateCustomPluginOutput, error)

CreateCustomPlugin provides a mock function with given fields: ctx, params, optFns

func (*IClient) CreateWorkerConfiguration

func (_m *IClient) CreateWorkerConfiguration(ctx context.Context, params *kafkaconnect.CreateWorkerConfigurationInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.CreateWorkerConfigurationOutput, error)

CreateWorkerConfiguration provides a mock function with given fields: ctx, params, optFns

func (*IClient) DeleteConnector

func (_m *IClient) DeleteConnector(ctx context.Context, params *kafkaconnect.DeleteConnectorInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.DeleteConnectorOutput, error)

DeleteConnector provides a mock function with given fields: ctx, params, optFns

func (*IClient) DeleteCustomPlugin

func (_m *IClient) DeleteCustomPlugin(ctx context.Context, params *kafkaconnect.DeleteCustomPluginInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.DeleteCustomPluginOutput, error)

DeleteCustomPlugin provides a mock function with given fields: ctx, params, optFns

func (*IClient) DeleteWorkerConfiguration

func (_m *IClient) DeleteWorkerConfiguration(ctx context.Context, params *kafkaconnect.DeleteWorkerConfigurationInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.DeleteWorkerConfigurationOutput, error)

DeleteWorkerConfiguration provides a mock function with given fields: ctx, params, optFns

func (*IClient) DescribeConnector

func (_m *IClient) DescribeConnector(ctx context.Context, params *kafkaconnect.DescribeConnectorInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.DescribeConnectorOutput, error)

DescribeConnector provides a mock function with given fields: ctx, params, optFns

func (*IClient) DescribeCustomPlugin

func (_m *IClient) DescribeCustomPlugin(ctx context.Context, params *kafkaconnect.DescribeCustomPluginInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.DescribeCustomPluginOutput, error)

DescribeCustomPlugin provides a mock function with given fields: ctx, params, optFns

func (*IClient) DescribeWorkerConfiguration

func (_m *IClient) DescribeWorkerConfiguration(ctx context.Context, params *kafkaconnect.DescribeWorkerConfigurationInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.DescribeWorkerConfigurationOutput, error)

DescribeWorkerConfiguration provides a mock function with given fields: ctx, params, optFns

func (*IClient) ListConnectors

func (_m *IClient) ListConnectors(ctx context.Context, params *kafkaconnect.ListConnectorsInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.ListConnectorsOutput, error)

ListConnectors provides a mock function with given fields: ctx, params, optFns

func (*IClient) ListCustomPlugins

func (_m *IClient) ListCustomPlugins(ctx context.Context, params *kafkaconnect.ListCustomPluginsInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.ListCustomPluginsOutput, error)

ListCustomPlugins provides a mock function with given fields: ctx, params, optFns

func (*IClient) ListTagsForResource

func (_m *IClient) ListTagsForResource(ctx context.Context, params *kafkaconnect.ListTagsForResourceInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.ListTagsForResourceOutput, error)

ListTagsForResource provides a mock function with given fields: ctx, params, optFns

func (*IClient) ListWorkerConfigurations

func (_m *IClient) ListWorkerConfigurations(ctx context.Context, params *kafkaconnect.ListWorkerConfigurationsInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.ListWorkerConfigurationsOutput, error)

ListWorkerConfigurations provides a mock function with given fields: ctx, params, optFns

func (*IClient) Options

func (_m *IClient) Options() kafkaconnect.Options

Options provides a mock function with given fields:

func (*IClient) TagResource

func (_m *IClient) TagResource(ctx context.Context, params *kafkaconnect.TagResourceInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.TagResourceOutput, error)

TagResource provides a mock function with given fields: ctx, params, optFns

func (*IClient) UntagResource

func (_m *IClient) UntagResource(ctx context.Context, params *kafkaconnect.UntagResourceInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.UntagResourceOutput, error)

UntagResource provides a mock function with given fields: ctx, params, optFns

func (*IClient) UpdateConnector

func (_m *IClient) UpdateConnector(ctx context.Context, params *kafkaconnect.UpdateConnectorInput, optFns ...func(*kafkaconnect.Options)) (*kafkaconnect.UpdateConnectorOutput, error)

UpdateConnector provides a mock function with given fields: ctx, params, optFns