Documentation ¶
Overview ¶
Package kafkaconnectmock is a generated GoMock package.
Index ¶
- type MockKafkaConnectAPI
- func (m *MockKafkaConnectAPI) CreateConnector(arg0 *kafkaconnect.CreateConnectorInput) (*kafkaconnect.CreateConnectorOutput, error)
- func (m *MockKafkaConnectAPI) CreateConnectorRequest(arg0 *kafkaconnect.CreateConnectorInput) (*request.Request, *kafkaconnect.CreateConnectorOutput)
- func (m *MockKafkaConnectAPI) CreateConnectorWithContext(arg0 context.Context, arg1 *kafkaconnect.CreateConnectorInput, ...) (*kafkaconnect.CreateConnectorOutput, error)
- func (m *MockKafkaConnectAPI) CreateCustomPlugin(arg0 *kafkaconnect.CreateCustomPluginInput) (*kafkaconnect.CreateCustomPluginOutput, error)
- func (m *MockKafkaConnectAPI) CreateCustomPluginRequest(arg0 *kafkaconnect.CreateCustomPluginInput) (*request.Request, *kafkaconnect.CreateCustomPluginOutput)
- func (m *MockKafkaConnectAPI) CreateCustomPluginWithContext(arg0 context.Context, arg1 *kafkaconnect.CreateCustomPluginInput, ...) (*kafkaconnect.CreateCustomPluginOutput, error)
- func (m *MockKafkaConnectAPI) CreateWorkerConfiguration(arg0 *kafkaconnect.CreateWorkerConfigurationInput) (*kafkaconnect.CreateWorkerConfigurationOutput, error)
- func (m *MockKafkaConnectAPI) CreateWorkerConfigurationRequest(arg0 *kafkaconnect.CreateWorkerConfigurationInput) (*request.Request, *kafkaconnect.CreateWorkerConfigurationOutput)
- func (m *MockKafkaConnectAPI) CreateWorkerConfigurationWithContext(arg0 context.Context, arg1 *kafkaconnect.CreateWorkerConfigurationInput, ...) (*kafkaconnect.CreateWorkerConfigurationOutput, error)
- func (m *MockKafkaConnectAPI) DeleteConnector(arg0 *kafkaconnect.DeleteConnectorInput) (*kafkaconnect.DeleteConnectorOutput, error)
- func (m *MockKafkaConnectAPI) DeleteConnectorRequest(arg0 *kafkaconnect.DeleteConnectorInput) (*request.Request, *kafkaconnect.DeleteConnectorOutput)
- func (m *MockKafkaConnectAPI) DeleteConnectorWithContext(arg0 context.Context, arg1 *kafkaconnect.DeleteConnectorInput, ...) (*kafkaconnect.DeleteConnectorOutput, error)
- func (m *MockKafkaConnectAPI) DeleteCustomPlugin(arg0 *kafkaconnect.DeleteCustomPluginInput) (*kafkaconnect.DeleteCustomPluginOutput, error)
- func (m *MockKafkaConnectAPI) DeleteCustomPluginRequest(arg0 *kafkaconnect.DeleteCustomPluginInput) (*request.Request, *kafkaconnect.DeleteCustomPluginOutput)
- func (m *MockKafkaConnectAPI) DeleteCustomPluginWithContext(arg0 context.Context, arg1 *kafkaconnect.DeleteCustomPluginInput, ...) (*kafkaconnect.DeleteCustomPluginOutput, error)
- func (m *MockKafkaConnectAPI) DescribeConnector(arg0 *kafkaconnect.DescribeConnectorInput) (*kafkaconnect.DescribeConnectorOutput, error)
- func (m *MockKafkaConnectAPI) DescribeConnectorRequest(arg0 *kafkaconnect.DescribeConnectorInput) (*request.Request, *kafkaconnect.DescribeConnectorOutput)
- func (m *MockKafkaConnectAPI) DescribeConnectorWithContext(arg0 context.Context, arg1 *kafkaconnect.DescribeConnectorInput, ...) (*kafkaconnect.DescribeConnectorOutput, error)
- func (m *MockKafkaConnectAPI) DescribeCustomPlugin(arg0 *kafkaconnect.DescribeCustomPluginInput) (*kafkaconnect.DescribeCustomPluginOutput, error)
- func (m *MockKafkaConnectAPI) DescribeCustomPluginRequest(arg0 *kafkaconnect.DescribeCustomPluginInput) (*request.Request, *kafkaconnect.DescribeCustomPluginOutput)
- func (m *MockKafkaConnectAPI) DescribeCustomPluginWithContext(arg0 context.Context, arg1 *kafkaconnect.DescribeCustomPluginInput, ...) (*kafkaconnect.DescribeCustomPluginOutput, error)
- func (m *MockKafkaConnectAPI) DescribeWorkerConfiguration(arg0 *kafkaconnect.DescribeWorkerConfigurationInput) (*kafkaconnect.DescribeWorkerConfigurationOutput, error)
- func (m *MockKafkaConnectAPI) DescribeWorkerConfigurationRequest(arg0 *kafkaconnect.DescribeWorkerConfigurationInput) (*request.Request, *kafkaconnect.DescribeWorkerConfigurationOutput)
- func (m *MockKafkaConnectAPI) DescribeWorkerConfigurationWithContext(arg0 context.Context, arg1 *kafkaconnect.DescribeWorkerConfigurationInput, ...) (*kafkaconnect.DescribeWorkerConfigurationOutput, error)
- func (m *MockKafkaConnectAPI) EXPECT() *MockKafkaConnectAPIMockRecorder
- func (m *MockKafkaConnectAPI) ListConnectors(arg0 *kafkaconnect.ListConnectorsInput) (*kafkaconnect.ListConnectorsOutput, error)
- func (m *MockKafkaConnectAPI) ListConnectorsPages(arg0 *kafkaconnect.ListConnectorsInput, ...) error
- func (m *MockKafkaConnectAPI) ListConnectorsPagesWithContext(arg0 context.Context, arg1 *kafkaconnect.ListConnectorsInput, ...) error
- func (m *MockKafkaConnectAPI) ListConnectorsRequest(arg0 *kafkaconnect.ListConnectorsInput) (*request.Request, *kafkaconnect.ListConnectorsOutput)
- func (m *MockKafkaConnectAPI) ListConnectorsWithContext(arg0 context.Context, arg1 *kafkaconnect.ListConnectorsInput, ...) (*kafkaconnect.ListConnectorsOutput, error)
- func (m *MockKafkaConnectAPI) ListCustomPlugins(arg0 *kafkaconnect.ListCustomPluginsInput) (*kafkaconnect.ListCustomPluginsOutput, error)
- func (m *MockKafkaConnectAPI) ListCustomPluginsPages(arg0 *kafkaconnect.ListCustomPluginsInput, ...) error
- func (m *MockKafkaConnectAPI) ListCustomPluginsPagesWithContext(arg0 context.Context, arg1 *kafkaconnect.ListCustomPluginsInput, ...) error
- func (m *MockKafkaConnectAPI) ListCustomPluginsRequest(arg0 *kafkaconnect.ListCustomPluginsInput) (*request.Request, *kafkaconnect.ListCustomPluginsOutput)
- func (m *MockKafkaConnectAPI) ListCustomPluginsWithContext(arg0 context.Context, arg1 *kafkaconnect.ListCustomPluginsInput, ...) (*kafkaconnect.ListCustomPluginsOutput, error)
- func (m *MockKafkaConnectAPI) ListWorkerConfigurations(arg0 *kafkaconnect.ListWorkerConfigurationsInput) (*kafkaconnect.ListWorkerConfigurationsOutput, error)
- func (m *MockKafkaConnectAPI) ListWorkerConfigurationsPages(arg0 *kafkaconnect.ListWorkerConfigurationsInput, ...) error
- func (m *MockKafkaConnectAPI) ListWorkerConfigurationsPagesWithContext(arg0 context.Context, arg1 *kafkaconnect.ListWorkerConfigurationsInput, ...) error
- func (m *MockKafkaConnectAPI) ListWorkerConfigurationsRequest(arg0 *kafkaconnect.ListWorkerConfigurationsInput) (*request.Request, *kafkaconnect.ListWorkerConfigurationsOutput)
- func (m *MockKafkaConnectAPI) ListWorkerConfigurationsWithContext(arg0 context.Context, arg1 *kafkaconnect.ListWorkerConfigurationsInput, ...) (*kafkaconnect.ListWorkerConfigurationsOutput, error)
- func (m *MockKafkaConnectAPI) UpdateConnector(arg0 *kafkaconnect.UpdateConnectorInput) (*kafkaconnect.UpdateConnectorOutput, error)
- func (m *MockKafkaConnectAPI) UpdateConnectorRequest(arg0 *kafkaconnect.UpdateConnectorInput) (*request.Request, *kafkaconnect.UpdateConnectorOutput)
- func (m *MockKafkaConnectAPI) UpdateConnectorWithContext(arg0 context.Context, arg1 *kafkaconnect.UpdateConnectorInput, ...) (*kafkaconnect.UpdateConnectorOutput, error)
- type MockKafkaConnectAPIMockRecorder
- func (mr *MockKafkaConnectAPIMockRecorder) CreateConnector(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) CreateConnectorRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) CreateConnectorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) CreateCustomPlugin(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) CreateCustomPluginRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) CreateCustomPluginWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) CreateWorkerConfiguration(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) CreateWorkerConfigurationRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) CreateWorkerConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DeleteConnector(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DeleteConnectorRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DeleteConnectorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DeleteCustomPlugin(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DeleteCustomPluginRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DeleteCustomPluginWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeConnector(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeConnectorRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeConnectorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeCustomPlugin(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeCustomPluginRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeCustomPluginWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeWorkerConfiguration(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeWorkerConfigurationRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) DescribeWorkerConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListConnectors(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListConnectorsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListConnectorsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListConnectorsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListConnectorsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPlugins(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPluginsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPluginsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPluginsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPluginsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurations(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) UpdateConnector(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) UpdateConnectorRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaConnectAPIMockRecorder) UpdateConnectorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockKafkaConnectAPI ¶
type MockKafkaConnectAPI struct {
// contains filtered or unexported fields
}
MockKafkaConnectAPI is a mock of KafkaConnectAPI interface
func NewMockKafkaConnectAPI ¶
func NewMockKafkaConnectAPI(ctrl *gomock.Controller) *MockKafkaConnectAPI
NewMockKafkaConnectAPI creates a new mock instance
func (*MockKafkaConnectAPI) CreateConnector ¶
func (m *MockKafkaConnectAPI) CreateConnector(arg0 *kafkaconnect.CreateConnectorInput) (*kafkaconnect.CreateConnectorOutput, error)
CreateConnector mocks base method
func (*MockKafkaConnectAPI) CreateConnectorRequest ¶
func (m *MockKafkaConnectAPI) CreateConnectorRequest(arg0 *kafkaconnect.CreateConnectorInput) (*request.Request, *kafkaconnect.CreateConnectorOutput)
CreateConnectorRequest mocks base method
func (*MockKafkaConnectAPI) CreateConnectorWithContext ¶
func (m *MockKafkaConnectAPI) CreateConnectorWithContext(arg0 context.Context, arg1 *kafkaconnect.CreateConnectorInput, arg2 ...request.Option) (*kafkaconnect.CreateConnectorOutput, error)
CreateConnectorWithContext mocks base method
func (*MockKafkaConnectAPI) CreateCustomPlugin ¶
func (m *MockKafkaConnectAPI) CreateCustomPlugin(arg0 *kafkaconnect.CreateCustomPluginInput) (*kafkaconnect.CreateCustomPluginOutput, error)
CreateCustomPlugin mocks base method
func (*MockKafkaConnectAPI) CreateCustomPluginRequest ¶
func (m *MockKafkaConnectAPI) CreateCustomPluginRequest(arg0 *kafkaconnect.CreateCustomPluginInput) (*request.Request, *kafkaconnect.CreateCustomPluginOutput)
CreateCustomPluginRequest mocks base method
func (*MockKafkaConnectAPI) CreateCustomPluginWithContext ¶
func (m *MockKafkaConnectAPI) CreateCustomPluginWithContext(arg0 context.Context, arg1 *kafkaconnect.CreateCustomPluginInput, arg2 ...request.Option) (*kafkaconnect.CreateCustomPluginOutput, error)
CreateCustomPluginWithContext mocks base method
func (*MockKafkaConnectAPI) CreateWorkerConfiguration ¶
func (m *MockKafkaConnectAPI) CreateWorkerConfiguration(arg0 *kafkaconnect.CreateWorkerConfigurationInput) (*kafkaconnect.CreateWorkerConfigurationOutput, error)
CreateWorkerConfiguration mocks base method
func (*MockKafkaConnectAPI) CreateWorkerConfigurationRequest ¶
func (m *MockKafkaConnectAPI) CreateWorkerConfigurationRequest(arg0 *kafkaconnect.CreateWorkerConfigurationInput) (*request.Request, *kafkaconnect.CreateWorkerConfigurationOutput)
CreateWorkerConfigurationRequest mocks base method
func (*MockKafkaConnectAPI) CreateWorkerConfigurationWithContext ¶
func (m *MockKafkaConnectAPI) CreateWorkerConfigurationWithContext(arg0 context.Context, arg1 *kafkaconnect.CreateWorkerConfigurationInput, arg2 ...request.Option) (*kafkaconnect.CreateWorkerConfigurationOutput, error)
CreateWorkerConfigurationWithContext mocks base method
func (*MockKafkaConnectAPI) DeleteConnector ¶
func (m *MockKafkaConnectAPI) DeleteConnector(arg0 *kafkaconnect.DeleteConnectorInput) (*kafkaconnect.DeleteConnectorOutput, error)
DeleteConnector mocks base method
func (*MockKafkaConnectAPI) DeleteConnectorRequest ¶
func (m *MockKafkaConnectAPI) DeleteConnectorRequest(arg0 *kafkaconnect.DeleteConnectorInput) (*request.Request, *kafkaconnect.DeleteConnectorOutput)
DeleteConnectorRequest mocks base method
func (*MockKafkaConnectAPI) DeleteConnectorWithContext ¶
func (m *MockKafkaConnectAPI) DeleteConnectorWithContext(arg0 context.Context, arg1 *kafkaconnect.DeleteConnectorInput, arg2 ...request.Option) (*kafkaconnect.DeleteConnectorOutput, error)
DeleteConnectorWithContext mocks base method
func (*MockKafkaConnectAPI) DeleteCustomPlugin ¶
func (m *MockKafkaConnectAPI) DeleteCustomPlugin(arg0 *kafkaconnect.DeleteCustomPluginInput) (*kafkaconnect.DeleteCustomPluginOutput, error)
DeleteCustomPlugin mocks base method
func (*MockKafkaConnectAPI) DeleteCustomPluginRequest ¶
func (m *MockKafkaConnectAPI) DeleteCustomPluginRequest(arg0 *kafkaconnect.DeleteCustomPluginInput) (*request.Request, *kafkaconnect.DeleteCustomPluginOutput)
DeleteCustomPluginRequest mocks base method
func (*MockKafkaConnectAPI) DeleteCustomPluginWithContext ¶
func (m *MockKafkaConnectAPI) DeleteCustomPluginWithContext(arg0 context.Context, arg1 *kafkaconnect.DeleteCustomPluginInput, arg2 ...request.Option) (*kafkaconnect.DeleteCustomPluginOutput, error)
DeleteCustomPluginWithContext mocks base method
func (*MockKafkaConnectAPI) DescribeConnector ¶
func (m *MockKafkaConnectAPI) DescribeConnector(arg0 *kafkaconnect.DescribeConnectorInput) (*kafkaconnect.DescribeConnectorOutput, error)
DescribeConnector mocks base method
func (*MockKafkaConnectAPI) DescribeConnectorRequest ¶
func (m *MockKafkaConnectAPI) DescribeConnectorRequest(arg0 *kafkaconnect.DescribeConnectorInput) (*request.Request, *kafkaconnect.DescribeConnectorOutput)
DescribeConnectorRequest mocks base method
func (*MockKafkaConnectAPI) DescribeConnectorWithContext ¶
func (m *MockKafkaConnectAPI) DescribeConnectorWithContext(arg0 context.Context, arg1 *kafkaconnect.DescribeConnectorInput, arg2 ...request.Option) (*kafkaconnect.DescribeConnectorOutput, error)
DescribeConnectorWithContext mocks base method
func (*MockKafkaConnectAPI) DescribeCustomPlugin ¶
func (m *MockKafkaConnectAPI) DescribeCustomPlugin(arg0 *kafkaconnect.DescribeCustomPluginInput) (*kafkaconnect.DescribeCustomPluginOutput, error)
DescribeCustomPlugin mocks base method
func (*MockKafkaConnectAPI) DescribeCustomPluginRequest ¶
func (m *MockKafkaConnectAPI) DescribeCustomPluginRequest(arg0 *kafkaconnect.DescribeCustomPluginInput) (*request.Request, *kafkaconnect.DescribeCustomPluginOutput)
DescribeCustomPluginRequest mocks base method
func (*MockKafkaConnectAPI) DescribeCustomPluginWithContext ¶
func (m *MockKafkaConnectAPI) DescribeCustomPluginWithContext(arg0 context.Context, arg1 *kafkaconnect.DescribeCustomPluginInput, arg2 ...request.Option) (*kafkaconnect.DescribeCustomPluginOutput, error)
DescribeCustomPluginWithContext mocks base method
func (*MockKafkaConnectAPI) DescribeWorkerConfiguration ¶
func (m *MockKafkaConnectAPI) DescribeWorkerConfiguration(arg0 *kafkaconnect.DescribeWorkerConfigurationInput) (*kafkaconnect.DescribeWorkerConfigurationOutput, error)
DescribeWorkerConfiguration mocks base method
func (*MockKafkaConnectAPI) DescribeWorkerConfigurationRequest ¶
func (m *MockKafkaConnectAPI) DescribeWorkerConfigurationRequest(arg0 *kafkaconnect.DescribeWorkerConfigurationInput) (*request.Request, *kafkaconnect.DescribeWorkerConfigurationOutput)
DescribeWorkerConfigurationRequest mocks base method
func (*MockKafkaConnectAPI) DescribeWorkerConfigurationWithContext ¶
func (m *MockKafkaConnectAPI) DescribeWorkerConfigurationWithContext(arg0 context.Context, arg1 *kafkaconnect.DescribeWorkerConfigurationInput, arg2 ...request.Option) (*kafkaconnect.DescribeWorkerConfigurationOutput, error)
DescribeWorkerConfigurationWithContext mocks base method
func (*MockKafkaConnectAPI) EXPECT ¶
func (m *MockKafkaConnectAPI) EXPECT() *MockKafkaConnectAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockKafkaConnectAPI) ListConnectors ¶
func (m *MockKafkaConnectAPI) ListConnectors(arg0 *kafkaconnect.ListConnectorsInput) (*kafkaconnect.ListConnectorsOutput, error)
ListConnectors mocks base method
func (*MockKafkaConnectAPI) ListConnectorsPages ¶
func (m *MockKafkaConnectAPI) ListConnectorsPages(arg0 *kafkaconnect.ListConnectorsInput, arg1 func(*kafkaconnect.ListConnectorsOutput, bool) bool) error
ListConnectorsPages mocks base method
func (*MockKafkaConnectAPI) ListConnectorsPagesWithContext ¶
func (m *MockKafkaConnectAPI) ListConnectorsPagesWithContext(arg0 context.Context, arg1 *kafkaconnect.ListConnectorsInput, arg2 func(*kafkaconnect.ListConnectorsOutput, bool) bool, arg3 ...request.Option) error
ListConnectorsPagesWithContext mocks base method
func (*MockKafkaConnectAPI) ListConnectorsRequest ¶
func (m *MockKafkaConnectAPI) ListConnectorsRequest(arg0 *kafkaconnect.ListConnectorsInput) (*request.Request, *kafkaconnect.ListConnectorsOutput)
ListConnectorsRequest mocks base method
func (*MockKafkaConnectAPI) ListConnectorsWithContext ¶
func (m *MockKafkaConnectAPI) ListConnectorsWithContext(arg0 context.Context, arg1 *kafkaconnect.ListConnectorsInput, arg2 ...request.Option) (*kafkaconnect.ListConnectorsOutput, error)
ListConnectorsWithContext mocks base method
func (*MockKafkaConnectAPI) ListCustomPlugins ¶
func (m *MockKafkaConnectAPI) ListCustomPlugins(arg0 *kafkaconnect.ListCustomPluginsInput) (*kafkaconnect.ListCustomPluginsOutput, error)
ListCustomPlugins mocks base method
func (*MockKafkaConnectAPI) ListCustomPluginsPages ¶
func (m *MockKafkaConnectAPI) ListCustomPluginsPages(arg0 *kafkaconnect.ListCustomPluginsInput, arg1 func(*kafkaconnect.ListCustomPluginsOutput, bool) bool) error
ListCustomPluginsPages mocks base method
func (*MockKafkaConnectAPI) ListCustomPluginsPagesWithContext ¶
func (m *MockKafkaConnectAPI) ListCustomPluginsPagesWithContext(arg0 context.Context, arg1 *kafkaconnect.ListCustomPluginsInput, arg2 func(*kafkaconnect.ListCustomPluginsOutput, bool) bool, arg3 ...request.Option) error
ListCustomPluginsPagesWithContext mocks base method
func (*MockKafkaConnectAPI) ListCustomPluginsRequest ¶
func (m *MockKafkaConnectAPI) ListCustomPluginsRequest(arg0 *kafkaconnect.ListCustomPluginsInput) (*request.Request, *kafkaconnect.ListCustomPluginsOutput)
ListCustomPluginsRequest mocks base method
func (*MockKafkaConnectAPI) ListCustomPluginsWithContext ¶
func (m *MockKafkaConnectAPI) ListCustomPluginsWithContext(arg0 context.Context, arg1 *kafkaconnect.ListCustomPluginsInput, arg2 ...request.Option) (*kafkaconnect.ListCustomPluginsOutput, error)
ListCustomPluginsWithContext mocks base method
func (*MockKafkaConnectAPI) ListWorkerConfigurations ¶
func (m *MockKafkaConnectAPI) ListWorkerConfigurations(arg0 *kafkaconnect.ListWorkerConfigurationsInput) (*kafkaconnect.ListWorkerConfigurationsOutput, error)
ListWorkerConfigurations mocks base method
func (*MockKafkaConnectAPI) ListWorkerConfigurationsPages ¶
func (m *MockKafkaConnectAPI) ListWorkerConfigurationsPages(arg0 *kafkaconnect.ListWorkerConfigurationsInput, arg1 func(*kafkaconnect.ListWorkerConfigurationsOutput, bool) bool) error
ListWorkerConfigurationsPages mocks base method
func (*MockKafkaConnectAPI) ListWorkerConfigurationsPagesWithContext ¶
func (m *MockKafkaConnectAPI) ListWorkerConfigurationsPagesWithContext(arg0 context.Context, arg1 *kafkaconnect.ListWorkerConfigurationsInput, arg2 func(*kafkaconnect.ListWorkerConfigurationsOutput, bool) bool, arg3 ...request.Option) error
ListWorkerConfigurationsPagesWithContext mocks base method
func (*MockKafkaConnectAPI) ListWorkerConfigurationsRequest ¶
func (m *MockKafkaConnectAPI) ListWorkerConfigurationsRequest(arg0 *kafkaconnect.ListWorkerConfigurationsInput) (*request.Request, *kafkaconnect.ListWorkerConfigurationsOutput)
ListWorkerConfigurationsRequest mocks base method
func (*MockKafkaConnectAPI) ListWorkerConfigurationsWithContext ¶
func (m *MockKafkaConnectAPI) ListWorkerConfigurationsWithContext(arg0 context.Context, arg1 *kafkaconnect.ListWorkerConfigurationsInput, arg2 ...request.Option) (*kafkaconnect.ListWorkerConfigurationsOutput, error)
ListWorkerConfigurationsWithContext mocks base method
func (*MockKafkaConnectAPI) UpdateConnector ¶
func (m *MockKafkaConnectAPI) UpdateConnector(arg0 *kafkaconnect.UpdateConnectorInput) (*kafkaconnect.UpdateConnectorOutput, error)
UpdateConnector mocks base method
func (*MockKafkaConnectAPI) UpdateConnectorRequest ¶
func (m *MockKafkaConnectAPI) UpdateConnectorRequest(arg0 *kafkaconnect.UpdateConnectorInput) (*request.Request, *kafkaconnect.UpdateConnectorOutput)
UpdateConnectorRequest mocks base method
func (*MockKafkaConnectAPI) UpdateConnectorWithContext ¶
func (m *MockKafkaConnectAPI) UpdateConnectorWithContext(arg0 context.Context, arg1 *kafkaconnect.UpdateConnectorInput, arg2 ...request.Option) (*kafkaconnect.UpdateConnectorOutput, error)
UpdateConnectorWithContext mocks base method
type MockKafkaConnectAPIMockRecorder ¶
type MockKafkaConnectAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockKafkaConnectAPIMockRecorder is the mock recorder for MockKafkaConnectAPI
func (*MockKafkaConnectAPIMockRecorder) CreateConnector ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateConnector(arg0 interface{}) *gomock.Call
CreateConnector indicates an expected call of CreateConnector
func (*MockKafkaConnectAPIMockRecorder) CreateConnectorRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateConnectorRequest(arg0 interface{}) *gomock.Call
CreateConnectorRequest indicates an expected call of CreateConnectorRequest
func (*MockKafkaConnectAPIMockRecorder) CreateConnectorWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateConnectorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateConnectorWithContext indicates an expected call of CreateConnectorWithContext
func (*MockKafkaConnectAPIMockRecorder) CreateCustomPlugin ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateCustomPlugin(arg0 interface{}) *gomock.Call
CreateCustomPlugin indicates an expected call of CreateCustomPlugin
func (*MockKafkaConnectAPIMockRecorder) CreateCustomPluginRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateCustomPluginRequest(arg0 interface{}) *gomock.Call
CreateCustomPluginRequest indicates an expected call of CreateCustomPluginRequest
func (*MockKafkaConnectAPIMockRecorder) CreateCustomPluginWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateCustomPluginWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateCustomPluginWithContext indicates an expected call of CreateCustomPluginWithContext
func (*MockKafkaConnectAPIMockRecorder) CreateWorkerConfiguration ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateWorkerConfiguration(arg0 interface{}) *gomock.Call
CreateWorkerConfiguration indicates an expected call of CreateWorkerConfiguration
func (*MockKafkaConnectAPIMockRecorder) CreateWorkerConfigurationRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateWorkerConfigurationRequest(arg0 interface{}) *gomock.Call
CreateWorkerConfigurationRequest indicates an expected call of CreateWorkerConfigurationRequest
func (*MockKafkaConnectAPIMockRecorder) CreateWorkerConfigurationWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) CreateWorkerConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateWorkerConfigurationWithContext indicates an expected call of CreateWorkerConfigurationWithContext
func (*MockKafkaConnectAPIMockRecorder) DeleteConnector ¶
func (mr *MockKafkaConnectAPIMockRecorder) DeleteConnector(arg0 interface{}) *gomock.Call
DeleteConnector indicates an expected call of DeleteConnector
func (*MockKafkaConnectAPIMockRecorder) DeleteConnectorRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) DeleteConnectorRequest(arg0 interface{}) *gomock.Call
DeleteConnectorRequest indicates an expected call of DeleteConnectorRequest
func (*MockKafkaConnectAPIMockRecorder) DeleteConnectorWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) DeleteConnectorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteConnectorWithContext indicates an expected call of DeleteConnectorWithContext
func (*MockKafkaConnectAPIMockRecorder) DeleteCustomPlugin ¶
func (mr *MockKafkaConnectAPIMockRecorder) DeleteCustomPlugin(arg0 interface{}) *gomock.Call
DeleteCustomPlugin indicates an expected call of DeleteCustomPlugin
func (*MockKafkaConnectAPIMockRecorder) DeleteCustomPluginRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) DeleteCustomPluginRequest(arg0 interface{}) *gomock.Call
DeleteCustomPluginRequest indicates an expected call of DeleteCustomPluginRequest
func (*MockKafkaConnectAPIMockRecorder) DeleteCustomPluginWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) DeleteCustomPluginWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteCustomPluginWithContext indicates an expected call of DeleteCustomPluginWithContext
func (*MockKafkaConnectAPIMockRecorder) DescribeConnector ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeConnector(arg0 interface{}) *gomock.Call
DescribeConnector indicates an expected call of DescribeConnector
func (*MockKafkaConnectAPIMockRecorder) DescribeConnectorRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeConnectorRequest(arg0 interface{}) *gomock.Call
DescribeConnectorRequest indicates an expected call of DescribeConnectorRequest
func (*MockKafkaConnectAPIMockRecorder) DescribeConnectorWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeConnectorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeConnectorWithContext indicates an expected call of DescribeConnectorWithContext
func (*MockKafkaConnectAPIMockRecorder) DescribeCustomPlugin ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeCustomPlugin(arg0 interface{}) *gomock.Call
DescribeCustomPlugin indicates an expected call of DescribeCustomPlugin
func (*MockKafkaConnectAPIMockRecorder) DescribeCustomPluginRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeCustomPluginRequest(arg0 interface{}) *gomock.Call
DescribeCustomPluginRequest indicates an expected call of DescribeCustomPluginRequest
func (*MockKafkaConnectAPIMockRecorder) DescribeCustomPluginWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeCustomPluginWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeCustomPluginWithContext indicates an expected call of DescribeCustomPluginWithContext
func (*MockKafkaConnectAPIMockRecorder) DescribeWorkerConfiguration ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeWorkerConfiguration(arg0 interface{}) *gomock.Call
DescribeWorkerConfiguration indicates an expected call of DescribeWorkerConfiguration
func (*MockKafkaConnectAPIMockRecorder) DescribeWorkerConfigurationRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeWorkerConfigurationRequest(arg0 interface{}) *gomock.Call
DescribeWorkerConfigurationRequest indicates an expected call of DescribeWorkerConfigurationRequest
func (*MockKafkaConnectAPIMockRecorder) DescribeWorkerConfigurationWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) DescribeWorkerConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeWorkerConfigurationWithContext indicates an expected call of DescribeWorkerConfigurationWithContext
func (*MockKafkaConnectAPIMockRecorder) ListConnectors ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListConnectors(arg0 interface{}) *gomock.Call
ListConnectors indicates an expected call of ListConnectors
func (*MockKafkaConnectAPIMockRecorder) ListConnectorsPages ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListConnectorsPages(arg0, arg1 interface{}) *gomock.Call
ListConnectorsPages indicates an expected call of ListConnectorsPages
func (*MockKafkaConnectAPIMockRecorder) ListConnectorsPagesWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListConnectorsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListConnectorsPagesWithContext indicates an expected call of ListConnectorsPagesWithContext
func (*MockKafkaConnectAPIMockRecorder) ListConnectorsRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListConnectorsRequest(arg0 interface{}) *gomock.Call
ListConnectorsRequest indicates an expected call of ListConnectorsRequest
func (*MockKafkaConnectAPIMockRecorder) ListConnectorsWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListConnectorsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListConnectorsWithContext indicates an expected call of ListConnectorsWithContext
func (*MockKafkaConnectAPIMockRecorder) ListCustomPlugins ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPlugins(arg0 interface{}) *gomock.Call
ListCustomPlugins indicates an expected call of ListCustomPlugins
func (*MockKafkaConnectAPIMockRecorder) ListCustomPluginsPages ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPluginsPages(arg0, arg1 interface{}) *gomock.Call
ListCustomPluginsPages indicates an expected call of ListCustomPluginsPages
func (*MockKafkaConnectAPIMockRecorder) ListCustomPluginsPagesWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPluginsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListCustomPluginsPagesWithContext indicates an expected call of ListCustomPluginsPagesWithContext
func (*MockKafkaConnectAPIMockRecorder) ListCustomPluginsRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPluginsRequest(arg0 interface{}) *gomock.Call
ListCustomPluginsRequest indicates an expected call of ListCustomPluginsRequest
func (*MockKafkaConnectAPIMockRecorder) ListCustomPluginsWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListCustomPluginsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListCustomPluginsWithContext indicates an expected call of ListCustomPluginsWithContext
func (*MockKafkaConnectAPIMockRecorder) ListWorkerConfigurations ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurations(arg0 interface{}) *gomock.Call
ListWorkerConfigurations indicates an expected call of ListWorkerConfigurations
func (*MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsPages ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsPages(arg0, arg1 interface{}) *gomock.Call
ListWorkerConfigurationsPages indicates an expected call of ListWorkerConfigurationsPages
func (*MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsPagesWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListWorkerConfigurationsPagesWithContext indicates an expected call of ListWorkerConfigurationsPagesWithContext
func (*MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsRequest(arg0 interface{}) *gomock.Call
ListWorkerConfigurationsRequest indicates an expected call of ListWorkerConfigurationsRequest
func (*MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) ListWorkerConfigurationsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListWorkerConfigurationsWithContext indicates an expected call of ListWorkerConfigurationsWithContext
func (*MockKafkaConnectAPIMockRecorder) UpdateConnector ¶
func (mr *MockKafkaConnectAPIMockRecorder) UpdateConnector(arg0 interface{}) *gomock.Call
UpdateConnector indicates an expected call of UpdateConnector
func (*MockKafkaConnectAPIMockRecorder) UpdateConnectorRequest ¶
func (mr *MockKafkaConnectAPIMockRecorder) UpdateConnectorRequest(arg0 interface{}) *gomock.Call
UpdateConnectorRequest indicates an expected call of UpdateConnectorRequest
func (*MockKafkaConnectAPIMockRecorder) UpdateConnectorWithContext ¶
func (mr *MockKafkaConnectAPIMockRecorder) UpdateConnectorWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateConnectorWithContext indicates an expected call of UpdateConnectorWithContext