Documentation ¶
Overview ¶
Package kafkamock is a generated GoMock package.
Index ¶
- type MockKafkaAPI
- func (m *MockKafkaAPI) BatchAssociateScramSecret(arg0 *kafka.BatchAssociateScramSecretInput) (*kafka.BatchAssociateScramSecretOutput, error)
- func (m *MockKafkaAPI) BatchAssociateScramSecretRequest(arg0 *kafka.BatchAssociateScramSecretInput) (*request.Request, *kafka.BatchAssociateScramSecretOutput)
- func (m *MockKafkaAPI) BatchAssociateScramSecretWithContext(arg0 context.Context, arg1 *kafka.BatchAssociateScramSecretInput, ...) (*kafka.BatchAssociateScramSecretOutput, error)
- func (m *MockKafkaAPI) BatchDisassociateScramSecret(arg0 *kafka.BatchDisassociateScramSecretInput) (*kafka.BatchDisassociateScramSecretOutput, error)
- func (m *MockKafkaAPI) BatchDisassociateScramSecretRequest(arg0 *kafka.BatchDisassociateScramSecretInput) (*request.Request, *kafka.BatchDisassociateScramSecretOutput)
- func (m *MockKafkaAPI) BatchDisassociateScramSecretWithContext(arg0 context.Context, arg1 *kafka.BatchDisassociateScramSecretInput, ...) (*kafka.BatchDisassociateScramSecretOutput, error)
- func (m *MockKafkaAPI) CreateCluster(arg0 *kafka.CreateClusterInput) (*kafka.CreateClusterOutput, error)
- func (m *MockKafkaAPI) CreateClusterRequest(arg0 *kafka.CreateClusterInput) (*request.Request, *kafka.CreateClusterOutput)
- func (m *MockKafkaAPI) CreateClusterWithContext(arg0 context.Context, arg1 *kafka.CreateClusterInput, arg2 ...request.Option) (*kafka.CreateClusterOutput, error)
- func (m *MockKafkaAPI) CreateConfiguration(arg0 *kafka.CreateConfigurationInput) (*kafka.CreateConfigurationOutput, error)
- func (m *MockKafkaAPI) CreateConfigurationRequest(arg0 *kafka.CreateConfigurationInput) (*request.Request, *kafka.CreateConfigurationOutput)
- func (m *MockKafkaAPI) CreateConfigurationWithContext(arg0 context.Context, arg1 *kafka.CreateConfigurationInput, ...) (*kafka.CreateConfigurationOutput, error)
- func (m *MockKafkaAPI) DeleteCluster(arg0 *kafka.DeleteClusterInput) (*kafka.DeleteClusterOutput, error)
- func (m *MockKafkaAPI) DeleteClusterRequest(arg0 *kafka.DeleteClusterInput) (*request.Request, *kafka.DeleteClusterOutput)
- func (m *MockKafkaAPI) DeleteClusterWithContext(arg0 context.Context, arg1 *kafka.DeleteClusterInput, arg2 ...request.Option) (*kafka.DeleteClusterOutput, error)
- func (m *MockKafkaAPI) DeleteConfiguration(arg0 *kafka.DeleteConfigurationInput) (*kafka.DeleteConfigurationOutput, error)
- func (m *MockKafkaAPI) DeleteConfigurationRequest(arg0 *kafka.DeleteConfigurationInput) (*request.Request, *kafka.DeleteConfigurationOutput)
- func (m *MockKafkaAPI) DeleteConfigurationWithContext(arg0 context.Context, arg1 *kafka.DeleteConfigurationInput, ...) (*kafka.DeleteConfigurationOutput, error)
- func (m *MockKafkaAPI) DescribeCluster(arg0 *kafka.DescribeClusterInput) (*kafka.DescribeClusterOutput, error)
- func (m *MockKafkaAPI) DescribeClusterOperation(arg0 *kafka.DescribeClusterOperationInput) (*kafka.DescribeClusterOperationOutput, error)
- func (m *MockKafkaAPI) DescribeClusterOperationRequest(arg0 *kafka.DescribeClusterOperationInput) (*request.Request, *kafka.DescribeClusterOperationOutput)
- func (m *MockKafkaAPI) DescribeClusterOperationWithContext(arg0 context.Context, arg1 *kafka.DescribeClusterOperationInput, ...) (*kafka.DescribeClusterOperationOutput, error)
- func (m *MockKafkaAPI) DescribeClusterRequest(arg0 *kafka.DescribeClusterInput) (*request.Request, *kafka.DescribeClusterOutput)
- func (m *MockKafkaAPI) DescribeClusterWithContext(arg0 context.Context, arg1 *kafka.DescribeClusterInput, arg2 ...request.Option) (*kafka.DescribeClusterOutput, error)
- func (m *MockKafkaAPI) DescribeConfiguration(arg0 *kafka.DescribeConfigurationInput) (*kafka.DescribeConfigurationOutput, error)
- func (m *MockKafkaAPI) DescribeConfigurationRequest(arg0 *kafka.DescribeConfigurationInput) (*request.Request, *kafka.DescribeConfigurationOutput)
- func (m *MockKafkaAPI) DescribeConfigurationRevision(arg0 *kafka.DescribeConfigurationRevisionInput) (*kafka.DescribeConfigurationRevisionOutput, error)
- func (m *MockKafkaAPI) DescribeConfigurationRevisionRequest(arg0 *kafka.DescribeConfigurationRevisionInput) (*request.Request, *kafka.DescribeConfigurationRevisionOutput)
- func (m *MockKafkaAPI) DescribeConfigurationRevisionWithContext(arg0 context.Context, arg1 *kafka.DescribeConfigurationRevisionInput, ...) (*kafka.DescribeConfigurationRevisionOutput, error)
- func (m *MockKafkaAPI) DescribeConfigurationWithContext(arg0 context.Context, arg1 *kafka.DescribeConfigurationInput, ...) (*kafka.DescribeConfigurationOutput, error)
- func (m *MockKafkaAPI) EXPECT() *MockKafkaAPIMockRecorder
- func (m *MockKafkaAPI) GetBootstrapBrokers(arg0 *kafka.GetBootstrapBrokersInput) (*kafka.GetBootstrapBrokersOutput, error)
- func (m *MockKafkaAPI) GetBootstrapBrokersRequest(arg0 *kafka.GetBootstrapBrokersInput) (*request.Request, *kafka.GetBootstrapBrokersOutput)
- func (m *MockKafkaAPI) GetBootstrapBrokersWithContext(arg0 context.Context, arg1 *kafka.GetBootstrapBrokersInput, ...) (*kafka.GetBootstrapBrokersOutput, error)
- func (m *MockKafkaAPI) GetCompatibleKafkaVersions(arg0 *kafka.GetCompatibleKafkaVersionsInput) (*kafka.GetCompatibleKafkaVersionsOutput, error)
- func (m *MockKafkaAPI) GetCompatibleKafkaVersionsRequest(arg0 *kafka.GetCompatibleKafkaVersionsInput) (*request.Request, *kafka.GetCompatibleKafkaVersionsOutput)
- func (m *MockKafkaAPI) GetCompatibleKafkaVersionsWithContext(arg0 context.Context, arg1 *kafka.GetCompatibleKafkaVersionsInput, ...) (*kafka.GetCompatibleKafkaVersionsOutput, error)
- func (m *MockKafkaAPI) ListClusterOperations(arg0 *kafka.ListClusterOperationsInput) (*kafka.ListClusterOperationsOutput, error)
- func (m *MockKafkaAPI) ListClusterOperationsPages(arg0 *kafka.ListClusterOperationsInput, ...) error
- func (m *MockKafkaAPI) ListClusterOperationsPagesWithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsInput, ...) error
- func (m *MockKafkaAPI) ListClusterOperationsRequest(arg0 *kafka.ListClusterOperationsInput) (*request.Request, *kafka.ListClusterOperationsOutput)
- func (m *MockKafkaAPI) ListClusterOperationsWithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsInput, ...) (*kafka.ListClusterOperationsOutput, error)
- func (m *MockKafkaAPI) ListClusters(arg0 *kafka.ListClustersInput) (*kafka.ListClustersOutput, error)
- func (m *MockKafkaAPI) ListClustersPages(arg0 *kafka.ListClustersInput, arg1 func(*kafka.ListClustersOutput, bool) bool) error
- func (m *MockKafkaAPI) ListClustersPagesWithContext(arg0 context.Context, arg1 *kafka.ListClustersInput, ...) error
- func (m *MockKafkaAPI) ListClustersRequest(arg0 *kafka.ListClustersInput) (*request.Request, *kafka.ListClustersOutput)
- func (m *MockKafkaAPI) ListClustersWithContext(arg0 context.Context, arg1 *kafka.ListClustersInput, arg2 ...request.Option) (*kafka.ListClustersOutput, error)
- func (m *MockKafkaAPI) ListConfigurationRevisions(arg0 *kafka.ListConfigurationRevisionsInput) (*kafka.ListConfigurationRevisionsOutput, error)
- func (m *MockKafkaAPI) ListConfigurationRevisionsPages(arg0 *kafka.ListConfigurationRevisionsInput, ...) error
- func (m *MockKafkaAPI) ListConfigurationRevisionsPagesWithContext(arg0 context.Context, arg1 *kafka.ListConfigurationRevisionsInput, ...) error
- func (m *MockKafkaAPI) ListConfigurationRevisionsRequest(arg0 *kafka.ListConfigurationRevisionsInput) (*request.Request, *kafka.ListConfigurationRevisionsOutput)
- func (m *MockKafkaAPI) ListConfigurationRevisionsWithContext(arg0 context.Context, arg1 *kafka.ListConfigurationRevisionsInput, ...) (*kafka.ListConfigurationRevisionsOutput, error)
- func (m *MockKafkaAPI) ListConfigurations(arg0 *kafka.ListConfigurationsInput) (*kafka.ListConfigurationsOutput, error)
- func (m *MockKafkaAPI) ListConfigurationsPages(arg0 *kafka.ListConfigurationsInput, ...) error
- func (m *MockKafkaAPI) ListConfigurationsPagesWithContext(arg0 context.Context, arg1 *kafka.ListConfigurationsInput, ...) error
- func (m *MockKafkaAPI) ListConfigurationsRequest(arg0 *kafka.ListConfigurationsInput) (*request.Request, *kafka.ListConfigurationsOutput)
- func (m *MockKafkaAPI) ListConfigurationsWithContext(arg0 context.Context, arg1 *kafka.ListConfigurationsInput, ...) (*kafka.ListConfigurationsOutput, error)
- func (m *MockKafkaAPI) ListKafkaVersions(arg0 *kafka.ListKafkaVersionsInput) (*kafka.ListKafkaVersionsOutput, error)
- func (m *MockKafkaAPI) ListKafkaVersionsPages(arg0 *kafka.ListKafkaVersionsInput, ...) error
- func (m *MockKafkaAPI) ListKafkaVersionsPagesWithContext(arg0 context.Context, arg1 *kafka.ListKafkaVersionsInput, ...) error
- func (m *MockKafkaAPI) ListKafkaVersionsRequest(arg0 *kafka.ListKafkaVersionsInput) (*request.Request, *kafka.ListKafkaVersionsOutput)
- func (m *MockKafkaAPI) ListKafkaVersionsWithContext(arg0 context.Context, arg1 *kafka.ListKafkaVersionsInput, ...) (*kafka.ListKafkaVersionsOutput, error)
- func (m *MockKafkaAPI) ListNodes(arg0 *kafka.ListNodesInput) (*kafka.ListNodesOutput, error)
- func (m *MockKafkaAPI) ListNodesPages(arg0 *kafka.ListNodesInput, arg1 func(*kafka.ListNodesOutput, bool) bool) error
- func (m *MockKafkaAPI) ListNodesPagesWithContext(arg0 context.Context, arg1 *kafka.ListNodesInput, ...) error
- func (m *MockKafkaAPI) ListNodesRequest(arg0 *kafka.ListNodesInput) (*request.Request, *kafka.ListNodesOutput)
- func (m *MockKafkaAPI) ListNodesWithContext(arg0 context.Context, arg1 *kafka.ListNodesInput, arg2 ...request.Option) (*kafka.ListNodesOutput, error)
- func (m *MockKafkaAPI) ListScramSecrets(arg0 *kafka.ListScramSecretsInput) (*kafka.ListScramSecretsOutput, error)
- func (m *MockKafkaAPI) ListScramSecretsPages(arg0 *kafka.ListScramSecretsInput, ...) error
- func (m *MockKafkaAPI) ListScramSecretsPagesWithContext(arg0 context.Context, arg1 *kafka.ListScramSecretsInput, ...) error
- func (m *MockKafkaAPI) ListScramSecretsRequest(arg0 *kafka.ListScramSecretsInput) (*request.Request, *kafka.ListScramSecretsOutput)
- func (m *MockKafkaAPI) ListScramSecretsWithContext(arg0 context.Context, arg1 *kafka.ListScramSecretsInput, ...) (*kafka.ListScramSecretsOutput, error)
- func (m *MockKafkaAPI) ListTagsForResource(arg0 *kafka.ListTagsForResourceInput) (*kafka.ListTagsForResourceOutput, error)
- func (m *MockKafkaAPI) ListTagsForResourceRequest(arg0 *kafka.ListTagsForResourceInput) (*request.Request, *kafka.ListTagsForResourceOutput)
- func (m *MockKafkaAPI) ListTagsForResourceWithContext(arg0 context.Context, arg1 *kafka.ListTagsForResourceInput, ...) (*kafka.ListTagsForResourceOutput, error)
- func (m *MockKafkaAPI) RebootBroker(arg0 *kafka.RebootBrokerInput) (*kafka.RebootBrokerOutput, error)
- func (m *MockKafkaAPI) RebootBrokerRequest(arg0 *kafka.RebootBrokerInput) (*request.Request, *kafka.RebootBrokerOutput)
- func (m *MockKafkaAPI) RebootBrokerWithContext(arg0 context.Context, arg1 *kafka.RebootBrokerInput, arg2 ...request.Option) (*kafka.RebootBrokerOutput, error)
- func (m *MockKafkaAPI) TagResource(arg0 *kafka.TagResourceInput) (*kafka.TagResourceOutput, error)
- func (m *MockKafkaAPI) TagResourceRequest(arg0 *kafka.TagResourceInput) (*request.Request, *kafka.TagResourceOutput)
- func (m *MockKafkaAPI) TagResourceWithContext(arg0 context.Context, arg1 *kafka.TagResourceInput, arg2 ...request.Option) (*kafka.TagResourceOutput, error)
- func (m *MockKafkaAPI) UntagResource(arg0 *kafka.UntagResourceInput) (*kafka.UntagResourceOutput, error)
- func (m *MockKafkaAPI) UntagResourceRequest(arg0 *kafka.UntagResourceInput) (*request.Request, *kafka.UntagResourceOutput)
- func (m *MockKafkaAPI) UntagResourceWithContext(arg0 context.Context, arg1 *kafka.UntagResourceInput, arg2 ...request.Option) (*kafka.UntagResourceOutput, error)
- func (m *MockKafkaAPI) UpdateBrokerCount(arg0 *kafka.UpdateBrokerCountInput) (*kafka.UpdateBrokerCountOutput, error)
- func (m *MockKafkaAPI) UpdateBrokerCountRequest(arg0 *kafka.UpdateBrokerCountInput) (*request.Request, *kafka.UpdateBrokerCountOutput)
- func (m *MockKafkaAPI) UpdateBrokerCountWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerCountInput, ...) (*kafka.UpdateBrokerCountOutput, error)
- func (m *MockKafkaAPI) UpdateBrokerStorage(arg0 *kafka.UpdateBrokerStorageInput) (*kafka.UpdateBrokerStorageOutput, error)
- func (m *MockKafkaAPI) UpdateBrokerStorageRequest(arg0 *kafka.UpdateBrokerStorageInput) (*request.Request, *kafka.UpdateBrokerStorageOutput)
- func (m *MockKafkaAPI) UpdateBrokerStorageWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerStorageInput, ...) (*kafka.UpdateBrokerStorageOutput, error)
- func (m *MockKafkaAPI) UpdateBrokerType(arg0 *kafka.UpdateBrokerTypeInput) (*kafka.UpdateBrokerTypeOutput, error)
- func (m *MockKafkaAPI) UpdateBrokerTypeRequest(arg0 *kafka.UpdateBrokerTypeInput) (*request.Request, *kafka.UpdateBrokerTypeOutput)
- func (m *MockKafkaAPI) UpdateBrokerTypeWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerTypeInput, ...) (*kafka.UpdateBrokerTypeOutput, error)
- func (m *MockKafkaAPI) UpdateClusterConfiguration(arg0 *kafka.UpdateClusterConfigurationInput) (*kafka.UpdateClusterConfigurationOutput, error)
- func (m *MockKafkaAPI) UpdateClusterConfigurationRequest(arg0 *kafka.UpdateClusterConfigurationInput) (*request.Request, *kafka.UpdateClusterConfigurationOutput)
- func (m *MockKafkaAPI) UpdateClusterConfigurationWithContext(arg0 context.Context, arg1 *kafka.UpdateClusterConfigurationInput, ...) (*kafka.UpdateClusterConfigurationOutput, error)
- func (m *MockKafkaAPI) UpdateClusterKafkaVersion(arg0 *kafka.UpdateClusterKafkaVersionInput) (*kafka.UpdateClusterKafkaVersionOutput, error)
- func (m *MockKafkaAPI) UpdateClusterKafkaVersionRequest(arg0 *kafka.UpdateClusterKafkaVersionInput) (*request.Request, *kafka.UpdateClusterKafkaVersionOutput)
- func (m *MockKafkaAPI) UpdateClusterKafkaVersionWithContext(arg0 context.Context, arg1 *kafka.UpdateClusterKafkaVersionInput, ...) (*kafka.UpdateClusterKafkaVersionOutput, error)
- func (m *MockKafkaAPI) UpdateConfiguration(arg0 *kafka.UpdateConfigurationInput) (*kafka.UpdateConfigurationOutput, error)
- func (m *MockKafkaAPI) UpdateConfigurationRequest(arg0 *kafka.UpdateConfigurationInput) (*request.Request, *kafka.UpdateConfigurationOutput)
- func (m *MockKafkaAPI) UpdateConfigurationWithContext(arg0 context.Context, arg1 *kafka.UpdateConfigurationInput, ...) (*kafka.UpdateConfigurationOutput, error)
- func (m *MockKafkaAPI) UpdateMonitoring(arg0 *kafka.UpdateMonitoringInput) (*kafka.UpdateMonitoringOutput, error)
- func (m *MockKafkaAPI) UpdateMonitoringRequest(arg0 *kafka.UpdateMonitoringInput) (*request.Request, *kafka.UpdateMonitoringOutput)
- func (m *MockKafkaAPI) UpdateMonitoringWithContext(arg0 context.Context, arg1 *kafka.UpdateMonitoringInput, ...) (*kafka.UpdateMonitoringOutput, error)
- type MockKafkaAPIMockRecorder
- func (mr *MockKafkaAPIMockRecorder) BatchAssociateScramSecret(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) BatchAssociateScramSecretRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) BatchAssociateScramSecretWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) BatchDisassociateScramSecret(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) BatchDisassociateScramSecretRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) BatchDisassociateScramSecretWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateCluster(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateClusterRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateClusterWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateConfiguration(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateConfigurationRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteCluster(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteClusterRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteClusterWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteConfiguration(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteConfigurationRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeCluster(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperation(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeConfiguration(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationRevision(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationRevisionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationRevisionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokers(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokersRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokersWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersions(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperations(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusters(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClustersPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClustersPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClustersRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClustersWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisions(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisionsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisionsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisionsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurations(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListConfigurationsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListKafkaVersions(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListKafkaVersionsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListKafkaVersionsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListKafkaVersionsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListKafkaVersionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListNodes(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListNodesPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListNodesPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListNodesRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListNodesWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListScramSecrets(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListScramSecretsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListScramSecretsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListScramSecretsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListScramSecretsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListTagsForResource(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListTagsForResourceRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListTagsForResourceWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) RebootBroker(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) RebootBrokerRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) RebootBrokerWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) TagResource(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) TagResourceRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) TagResourceWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UntagResource(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UntagResourceRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UntagResourceWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCount(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCountRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCountWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorage(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorageRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorageWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerType(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerTypeRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateBrokerTypeWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfiguration(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfigurationRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersion(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateConfiguration(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateConfigurationRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateMonitoring(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateMonitoringRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateMonitoringWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockKafkaAPI ¶
type MockKafkaAPI struct {
// contains filtered or unexported fields
}
MockKafkaAPI is a mock of KafkaAPI interface
func NewMockKafkaAPI ¶
func NewMockKafkaAPI(ctrl *gomock.Controller) *MockKafkaAPI
NewMockKafkaAPI creates a new mock instance
func (*MockKafkaAPI) BatchAssociateScramSecret ¶
func (m *MockKafkaAPI) BatchAssociateScramSecret(arg0 *kafka.BatchAssociateScramSecretInput) (*kafka.BatchAssociateScramSecretOutput, error)
BatchAssociateScramSecret mocks base method
func (*MockKafkaAPI) BatchAssociateScramSecretRequest ¶
func (m *MockKafkaAPI) BatchAssociateScramSecretRequest(arg0 *kafka.BatchAssociateScramSecretInput) (*request.Request, *kafka.BatchAssociateScramSecretOutput)
BatchAssociateScramSecretRequest mocks base method
func (*MockKafkaAPI) BatchAssociateScramSecretWithContext ¶
func (m *MockKafkaAPI) BatchAssociateScramSecretWithContext(arg0 context.Context, arg1 *kafka.BatchAssociateScramSecretInput, arg2 ...request.Option) (*kafka.BatchAssociateScramSecretOutput, error)
BatchAssociateScramSecretWithContext mocks base method
func (*MockKafkaAPI) BatchDisassociateScramSecret ¶
func (m *MockKafkaAPI) BatchDisassociateScramSecret(arg0 *kafka.BatchDisassociateScramSecretInput) (*kafka.BatchDisassociateScramSecretOutput, error)
BatchDisassociateScramSecret mocks base method
func (*MockKafkaAPI) BatchDisassociateScramSecretRequest ¶
func (m *MockKafkaAPI) BatchDisassociateScramSecretRequest(arg0 *kafka.BatchDisassociateScramSecretInput) (*request.Request, *kafka.BatchDisassociateScramSecretOutput)
BatchDisassociateScramSecretRequest mocks base method
func (*MockKafkaAPI) BatchDisassociateScramSecretWithContext ¶
func (m *MockKafkaAPI) BatchDisassociateScramSecretWithContext(arg0 context.Context, arg1 *kafka.BatchDisassociateScramSecretInput, arg2 ...request.Option) (*kafka.BatchDisassociateScramSecretOutput, error)
BatchDisassociateScramSecretWithContext mocks base method
func (*MockKafkaAPI) CreateCluster ¶
func (m *MockKafkaAPI) CreateCluster(arg0 *kafka.CreateClusterInput) (*kafka.CreateClusterOutput, error)
CreateCluster mocks base method
func (*MockKafkaAPI) CreateClusterRequest ¶
func (m *MockKafkaAPI) CreateClusterRequest(arg0 *kafka.CreateClusterInput) (*request.Request, *kafka.CreateClusterOutput)
CreateClusterRequest mocks base method
func (*MockKafkaAPI) CreateClusterWithContext ¶
func (m *MockKafkaAPI) CreateClusterWithContext(arg0 context.Context, arg1 *kafka.CreateClusterInput, arg2 ...request.Option) (*kafka.CreateClusterOutput, error)
CreateClusterWithContext mocks base method
func (*MockKafkaAPI) CreateConfiguration ¶
func (m *MockKafkaAPI) CreateConfiguration(arg0 *kafka.CreateConfigurationInput) (*kafka.CreateConfigurationOutput, error)
CreateConfiguration mocks base method
func (*MockKafkaAPI) CreateConfigurationRequest ¶
func (m *MockKafkaAPI) CreateConfigurationRequest(arg0 *kafka.CreateConfigurationInput) (*request.Request, *kafka.CreateConfigurationOutput)
CreateConfigurationRequest mocks base method
func (*MockKafkaAPI) CreateConfigurationWithContext ¶
func (m *MockKafkaAPI) CreateConfigurationWithContext(arg0 context.Context, arg1 *kafka.CreateConfigurationInput, arg2 ...request.Option) (*kafka.CreateConfigurationOutput, error)
CreateConfigurationWithContext mocks base method
func (*MockKafkaAPI) DeleteCluster ¶
func (m *MockKafkaAPI) DeleteCluster(arg0 *kafka.DeleteClusterInput) (*kafka.DeleteClusterOutput, error)
DeleteCluster mocks base method
func (*MockKafkaAPI) DeleteClusterRequest ¶
func (m *MockKafkaAPI) DeleteClusterRequest(arg0 *kafka.DeleteClusterInput) (*request.Request, *kafka.DeleteClusterOutput)
DeleteClusterRequest mocks base method
func (*MockKafkaAPI) DeleteClusterWithContext ¶
func (m *MockKafkaAPI) DeleteClusterWithContext(arg0 context.Context, arg1 *kafka.DeleteClusterInput, arg2 ...request.Option) (*kafka.DeleteClusterOutput, error)
DeleteClusterWithContext mocks base method
func (*MockKafkaAPI) DeleteConfiguration ¶
func (m *MockKafkaAPI) DeleteConfiguration(arg0 *kafka.DeleteConfigurationInput) (*kafka.DeleteConfigurationOutput, error)
DeleteConfiguration mocks base method
func (*MockKafkaAPI) DeleteConfigurationRequest ¶
func (m *MockKafkaAPI) DeleteConfigurationRequest(arg0 *kafka.DeleteConfigurationInput) (*request.Request, *kafka.DeleteConfigurationOutput)
DeleteConfigurationRequest mocks base method
func (*MockKafkaAPI) DeleteConfigurationWithContext ¶
func (m *MockKafkaAPI) DeleteConfigurationWithContext(arg0 context.Context, arg1 *kafka.DeleteConfigurationInput, arg2 ...request.Option) (*kafka.DeleteConfigurationOutput, error)
DeleteConfigurationWithContext mocks base method
func (*MockKafkaAPI) DescribeCluster ¶
func (m *MockKafkaAPI) DescribeCluster(arg0 *kafka.DescribeClusterInput) (*kafka.DescribeClusterOutput, error)
DescribeCluster mocks base method
func (*MockKafkaAPI) DescribeClusterOperation ¶
func (m *MockKafkaAPI) DescribeClusterOperation(arg0 *kafka.DescribeClusterOperationInput) (*kafka.DescribeClusterOperationOutput, error)
DescribeClusterOperation mocks base method
func (*MockKafkaAPI) DescribeClusterOperationRequest ¶
func (m *MockKafkaAPI) DescribeClusterOperationRequest(arg0 *kafka.DescribeClusterOperationInput) (*request.Request, *kafka.DescribeClusterOperationOutput)
DescribeClusterOperationRequest mocks base method
func (*MockKafkaAPI) DescribeClusterOperationWithContext ¶
func (m *MockKafkaAPI) DescribeClusterOperationWithContext(arg0 context.Context, arg1 *kafka.DescribeClusterOperationInput, arg2 ...request.Option) (*kafka.DescribeClusterOperationOutput, error)
DescribeClusterOperationWithContext mocks base method
func (*MockKafkaAPI) DescribeClusterRequest ¶
func (m *MockKafkaAPI) DescribeClusterRequest(arg0 *kafka.DescribeClusterInput) (*request.Request, *kafka.DescribeClusterOutput)
DescribeClusterRequest mocks base method
func (*MockKafkaAPI) DescribeClusterWithContext ¶
func (m *MockKafkaAPI) DescribeClusterWithContext(arg0 context.Context, arg1 *kafka.DescribeClusterInput, arg2 ...request.Option) (*kafka.DescribeClusterOutput, error)
DescribeClusterWithContext mocks base method
func (*MockKafkaAPI) DescribeConfiguration ¶
func (m *MockKafkaAPI) DescribeConfiguration(arg0 *kafka.DescribeConfigurationInput) (*kafka.DescribeConfigurationOutput, error)
DescribeConfiguration mocks base method
func (*MockKafkaAPI) DescribeConfigurationRequest ¶
func (m *MockKafkaAPI) DescribeConfigurationRequest(arg0 *kafka.DescribeConfigurationInput) (*request.Request, *kafka.DescribeConfigurationOutput)
DescribeConfigurationRequest mocks base method
func (*MockKafkaAPI) DescribeConfigurationRevision ¶
func (m *MockKafkaAPI) DescribeConfigurationRevision(arg0 *kafka.DescribeConfigurationRevisionInput) (*kafka.DescribeConfigurationRevisionOutput, error)
DescribeConfigurationRevision mocks base method
func (*MockKafkaAPI) DescribeConfigurationRevisionRequest ¶
func (m *MockKafkaAPI) DescribeConfigurationRevisionRequest(arg0 *kafka.DescribeConfigurationRevisionInput) (*request.Request, *kafka.DescribeConfigurationRevisionOutput)
DescribeConfigurationRevisionRequest mocks base method
func (*MockKafkaAPI) DescribeConfigurationRevisionWithContext ¶
func (m *MockKafkaAPI) DescribeConfigurationRevisionWithContext(arg0 context.Context, arg1 *kafka.DescribeConfigurationRevisionInput, arg2 ...request.Option) (*kafka.DescribeConfigurationRevisionOutput, error)
DescribeConfigurationRevisionWithContext mocks base method
func (*MockKafkaAPI) DescribeConfigurationWithContext ¶
func (m *MockKafkaAPI) DescribeConfigurationWithContext(arg0 context.Context, arg1 *kafka.DescribeConfigurationInput, arg2 ...request.Option) (*kafka.DescribeConfigurationOutput, error)
DescribeConfigurationWithContext mocks base method
func (*MockKafkaAPI) EXPECT ¶
func (m *MockKafkaAPI) EXPECT() *MockKafkaAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockKafkaAPI) GetBootstrapBrokers ¶
func (m *MockKafkaAPI) GetBootstrapBrokers(arg0 *kafka.GetBootstrapBrokersInput) (*kafka.GetBootstrapBrokersOutput, error)
GetBootstrapBrokers mocks base method
func (*MockKafkaAPI) GetBootstrapBrokersRequest ¶
func (m *MockKafkaAPI) GetBootstrapBrokersRequest(arg0 *kafka.GetBootstrapBrokersInput) (*request.Request, *kafka.GetBootstrapBrokersOutput)
GetBootstrapBrokersRequest mocks base method
func (*MockKafkaAPI) GetBootstrapBrokersWithContext ¶
func (m *MockKafkaAPI) GetBootstrapBrokersWithContext(arg0 context.Context, arg1 *kafka.GetBootstrapBrokersInput, arg2 ...request.Option) (*kafka.GetBootstrapBrokersOutput, error)
GetBootstrapBrokersWithContext mocks base method
func (*MockKafkaAPI) GetCompatibleKafkaVersions ¶
func (m *MockKafkaAPI) GetCompatibleKafkaVersions(arg0 *kafka.GetCompatibleKafkaVersionsInput) (*kafka.GetCompatibleKafkaVersionsOutput, error)
GetCompatibleKafkaVersions mocks base method
func (*MockKafkaAPI) GetCompatibleKafkaVersionsRequest ¶
func (m *MockKafkaAPI) GetCompatibleKafkaVersionsRequest(arg0 *kafka.GetCompatibleKafkaVersionsInput) (*request.Request, *kafka.GetCompatibleKafkaVersionsOutput)
GetCompatibleKafkaVersionsRequest mocks base method
func (*MockKafkaAPI) GetCompatibleKafkaVersionsWithContext ¶
func (m *MockKafkaAPI) GetCompatibleKafkaVersionsWithContext(arg0 context.Context, arg1 *kafka.GetCompatibleKafkaVersionsInput, arg2 ...request.Option) (*kafka.GetCompatibleKafkaVersionsOutput, error)
GetCompatibleKafkaVersionsWithContext mocks base method
func (*MockKafkaAPI) ListClusterOperations ¶
func (m *MockKafkaAPI) ListClusterOperations(arg0 *kafka.ListClusterOperationsInput) (*kafka.ListClusterOperationsOutput, error)
ListClusterOperations mocks base method
func (*MockKafkaAPI) ListClusterOperationsPages ¶
func (m *MockKafkaAPI) ListClusterOperationsPages(arg0 *kafka.ListClusterOperationsInput, arg1 func(*kafka.ListClusterOperationsOutput, bool) bool) error
ListClusterOperationsPages mocks base method
func (*MockKafkaAPI) ListClusterOperationsPagesWithContext ¶
func (m *MockKafkaAPI) ListClusterOperationsPagesWithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsInput, arg2 func(*kafka.ListClusterOperationsOutput, bool) bool, arg3 ...request.Option) error
ListClusterOperationsPagesWithContext mocks base method
func (*MockKafkaAPI) ListClusterOperationsRequest ¶
func (m *MockKafkaAPI) ListClusterOperationsRequest(arg0 *kafka.ListClusterOperationsInput) (*request.Request, *kafka.ListClusterOperationsOutput)
ListClusterOperationsRequest mocks base method
func (*MockKafkaAPI) ListClusterOperationsWithContext ¶
func (m *MockKafkaAPI) ListClusterOperationsWithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsInput, arg2 ...request.Option) (*kafka.ListClusterOperationsOutput, error)
ListClusterOperationsWithContext mocks base method
func (*MockKafkaAPI) ListClusters ¶
func (m *MockKafkaAPI) ListClusters(arg0 *kafka.ListClustersInput) (*kafka.ListClustersOutput, error)
ListClusters mocks base method
func (*MockKafkaAPI) ListClustersPages ¶
func (m *MockKafkaAPI) ListClustersPages(arg0 *kafka.ListClustersInput, arg1 func(*kafka.ListClustersOutput, bool) bool) error
ListClustersPages mocks base method
func (*MockKafkaAPI) ListClustersPagesWithContext ¶
func (m *MockKafkaAPI) ListClustersPagesWithContext(arg0 context.Context, arg1 *kafka.ListClustersInput, arg2 func(*kafka.ListClustersOutput, bool) bool, arg3 ...request.Option) error
ListClustersPagesWithContext mocks base method
func (*MockKafkaAPI) ListClustersRequest ¶
func (m *MockKafkaAPI) ListClustersRequest(arg0 *kafka.ListClustersInput) (*request.Request, *kafka.ListClustersOutput)
ListClustersRequest mocks base method
func (*MockKafkaAPI) ListClustersWithContext ¶
func (m *MockKafkaAPI) ListClustersWithContext(arg0 context.Context, arg1 *kafka.ListClustersInput, arg2 ...request.Option) (*kafka.ListClustersOutput, error)
ListClustersWithContext mocks base method
func (*MockKafkaAPI) ListConfigurationRevisions ¶
func (m *MockKafkaAPI) ListConfigurationRevisions(arg0 *kafka.ListConfigurationRevisionsInput) (*kafka.ListConfigurationRevisionsOutput, error)
ListConfigurationRevisions mocks base method
func (*MockKafkaAPI) ListConfigurationRevisionsPages ¶
func (m *MockKafkaAPI) ListConfigurationRevisionsPages(arg0 *kafka.ListConfigurationRevisionsInput, arg1 func(*kafka.ListConfigurationRevisionsOutput, bool) bool) error
ListConfigurationRevisionsPages mocks base method
func (*MockKafkaAPI) ListConfigurationRevisionsPagesWithContext ¶
func (m *MockKafkaAPI) ListConfigurationRevisionsPagesWithContext(arg0 context.Context, arg1 *kafka.ListConfigurationRevisionsInput, arg2 func(*kafka.ListConfigurationRevisionsOutput, bool) bool, arg3 ...request.Option) error
ListConfigurationRevisionsPagesWithContext mocks base method
func (*MockKafkaAPI) ListConfigurationRevisionsRequest ¶
func (m *MockKafkaAPI) ListConfigurationRevisionsRequest(arg0 *kafka.ListConfigurationRevisionsInput) (*request.Request, *kafka.ListConfigurationRevisionsOutput)
ListConfigurationRevisionsRequest mocks base method
func (*MockKafkaAPI) ListConfigurationRevisionsWithContext ¶
func (m *MockKafkaAPI) ListConfigurationRevisionsWithContext(arg0 context.Context, arg1 *kafka.ListConfigurationRevisionsInput, arg2 ...request.Option) (*kafka.ListConfigurationRevisionsOutput, error)
ListConfigurationRevisionsWithContext mocks base method
func (*MockKafkaAPI) ListConfigurations ¶
func (m *MockKafkaAPI) ListConfigurations(arg0 *kafka.ListConfigurationsInput) (*kafka.ListConfigurationsOutput, error)
ListConfigurations mocks base method
func (*MockKafkaAPI) ListConfigurationsPages ¶
func (m *MockKafkaAPI) ListConfigurationsPages(arg0 *kafka.ListConfigurationsInput, arg1 func(*kafka.ListConfigurationsOutput, bool) bool) error
ListConfigurationsPages mocks base method
func (*MockKafkaAPI) ListConfigurationsPagesWithContext ¶
func (m *MockKafkaAPI) ListConfigurationsPagesWithContext(arg0 context.Context, arg1 *kafka.ListConfigurationsInput, arg2 func(*kafka.ListConfigurationsOutput, bool) bool, arg3 ...request.Option) error
ListConfigurationsPagesWithContext mocks base method
func (*MockKafkaAPI) ListConfigurationsRequest ¶
func (m *MockKafkaAPI) ListConfigurationsRequest(arg0 *kafka.ListConfigurationsInput) (*request.Request, *kafka.ListConfigurationsOutput)
ListConfigurationsRequest mocks base method
func (*MockKafkaAPI) ListConfigurationsWithContext ¶
func (m *MockKafkaAPI) ListConfigurationsWithContext(arg0 context.Context, arg1 *kafka.ListConfigurationsInput, arg2 ...request.Option) (*kafka.ListConfigurationsOutput, error)
ListConfigurationsWithContext mocks base method
func (*MockKafkaAPI) ListKafkaVersions ¶
func (m *MockKafkaAPI) ListKafkaVersions(arg0 *kafka.ListKafkaVersionsInput) (*kafka.ListKafkaVersionsOutput, error)
ListKafkaVersions mocks base method
func (*MockKafkaAPI) ListKafkaVersionsPages ¶
func (m *MockKafkaAPI) ListKafkaVersionsPages(arg0 *kafka.ListKafkaVersionsInput, arg1 func(*kafka.ListKafkaVersionsOutput, bool) bool) error
ListKafkaVersionsPages mocks base method
func (*MockKafkaAPI) ListKafkaVersionsPagesWithContext ¶
func (m *MockKafkaAPI) ListKafkaVersionsPagesWithContext(arg0 context.Context, arg1 *kafka.ListKafkaVersionsInput, arg2 func(*kafka.ListKafkaVersionsOutput, bool) bool, arg3 ...request.Option) error
ListKafkaVersionsPagesWithContext mocks base method
func (*MockKafkaAPI) ListKafkaVersionsRequest ¶
func (m *MockKafkaAPI) ListKafkaVersionsRequest(arg0 *kafka.ListKafkaVersionsInput) (*request.Request, *kafka.ListKafkaVersionsOutput)
ListKafkaVersionsRequest mocks base method
func (*MockKafkaAPI) ListKafkaVersionsWithContext ¶
func (m *MockKafkaAPI) ListKafkaVersionsWithContext(arg0 context.Context, arg1 *kafka.ListKafkaVersionsInput, arg2 ...request.Option) (*kafka.ListKafkaVersionsOutput, error)
ListKafkaVersionsWithContext mocks base method
func (*MockKafkaAPI) ListNodes ¶
func (m *MockKafkaAPI) ListNodes(arg0 *kafka.ListNodesInput) (*kafka.ListNodesOutput, error)
ListNodes mocks base method
func (*MockKafkaAPI) ListNodesPages ¶
func (m *MockKafkaAPI) ListNodesPages(arg0 *kafka.ListNodesInput, arg1 func(*kafka.ListNodesOutput, bool) bool) error
ListNodesPages mocks base method
func (*MockKafkaAPI) ListNodesPagesWithContext ¶
func (m *MockKafkaAPI) ListNodesPagesWithContext(arg0 context.Context, arg1 *kafka.ListNodesInput, arg2 func(*kafka.ListNodesOutput, bool) bool, arg3 ...request.Option) error
ListNodesPagesWithContext mocks base method
func (*MockKafkaAPI) ListNodesRequest ¶
func (m *MockKafkaAPI) ListNodesRequest(arg0 *kafka.ListNodesInput) (*request.Request, *kafka.ListNodesOutput)
ListNodesRequest mocks base method
func (*MockKafkaAPI) ListNodesWithContext ¶
func (m *MockKafkaAPI) ListNodesWithContext(arg0 context.Context, arg1 *kafka.ListNodesInput, arg2 ...request.Option) (*kafka.ListNodesOutput, error)
ListNodesWithContext mocks base method
func (*MockKafkaAPI) ListScramSecrets ¶
func (m *MockKafkaAPI) ListScramSecrets(arg0 *kafka.ListScramSecretsInput) (*kafka.ListScramSecretsOutput, error)
ListScramSecrets mocks base method
func (*MockKafkaAPI) ListScramSecretsPages ¶
func (m *MockKafkaAPI) ListScramSecretsPages(arg0 *kafka.ListScramSecretsInput, arg1 func(*kafka.ListScramSecretsOutput, bool) bool) error
ListScramSecretsPages mocks base method
func (*MockKafkaAPI) ListScramSecretsPagesWithContext ¶
func (m *MockKafkaAPI) ListScramSecretsPagesWithContext(arg0 context.Context, arg1 *kafka.ListScramSecretsInput, arg2 func(*kafka.ListScramSecretsOutput, bool) bool, arg3 ...request.Option) error
ListScramSecretsPagesWithContext mocks base method
func (*MockKafkaAPI) ListScramSecretsRequest ¶
func (m *MockKafkaAPI) ListScramSecretsRequest(arg0 *kafka.ListScramSecretsInput) (*request.Request, *kafka.ListScramSecretsOutput)
ListScramSecretsRequest mocks base method
func (*MockKafkaAPI) ListScramSecretsWithContext ¶
func (m *MockKafkaAPI) ListScramSecretsWithContext(arg0 context.Context, arg1 *kafka.ListScramSecretsInput, arg2 ...request.Option) (*kafka.ListScramSecretsOutput, error)
ListScramSecretsWithContext mocks base method
func (*MockKafkaAPI) ListTagsForResource ¶
func (m *MockKafkaAPI) ListTagsForResource(arg0 *kafka.ListTagsForResourceInput) (*kafka.ListTagsForResourceOutput, error)
ListTagsForResource mocks base method
func (*MockKafkaAPI) ListTagsForResourceRequest ¶
func (m *MockKafkaAPI) ListTagsForResourceRequest(arg0 *kafka.ListTagsForResourceInput) (*request.Request, *kafka.ListTagsForResourceOutput)
ListTagsForResourceRequest mocks base method
func (*MockKafkaAPI) ListTagsForResourceWithContext ¶
func (m *MockKafkaAPI) ListTagsForResourceWithContext(arg0 context.Context, arg1 *kafka.ListTagsForResourceInput, arg2 ...request.Option) (*kafka.ListTagsForResourceOutput, error)
ListTagsForResourceWithContext mocks base method
func (*MockKafkaAPI) RebootBroker ¶
func (m *MockKafkaAPI) RebootBroker(arg0 *kafka.RebootBrokerInput) (*kafka.RebootBrokerOutput, error)
RebootBroker mocks base method
func (*MockKafkaAPI) RebootBrokerRequest ¶
func (m *MockKafkaAPI) RebootBrokerRequest(arg0 *kafka.RebootBrokerInput) (*request.Request, *kafka.RebootBrokerOutput)
RebootBrokerRequest mocks base method
func (*MockKafkaAPI) RebootBrokerWithContext ¶
func (m *MockKafkaAPI) RebootBrokerWithContext(arg0 context.Context, arg1 *kafka.RebootBrokerInput, arg2 ...request.Option) (*kafka.RebootBrokerOutput, error)
RebootBrokerWithContext mocks base method
func (*MockKafkaAPI) TagResource ¶
func (m *MockKafkaAPI) TagResource(arg0 *kafka.TagResourceInput) (*kafka.TagResourceOutput, error)
TagResource mocks base method
func (*MockKafkaAPI) TagResourceRequest ¶
func (m *MockKafkaAPI) TagResourceRequest(arg0 *kafka.TagResourceInput) (*request.Request, *kafka.TagResourceOutput)
TagResourceRequest mocks base method
func (*MockKafkaAPI) TagResourceWithContext ¶
func (m *MockKafkaAPI) TagResourceWithContext(arg0 context.Context, arg1 *kafka.TagResourceInput, arg2 ...request.Option) (*kafka.TagResourceOutput, error)
TagResourceWithContext mocks base method
func (*MockKafkaAPI) UntagResource ¶
func (m *MockKafkaAPI) UntagResource(arg0 *kafka.UntagResourceInput) (*kafka.UntagResourceOutput, error)
UntagResource mocks base method
func (*MockKafkaAPI) UntagResourceRequest ¶
func (m *MockKafkaAPI) UntagResourceRequest(arg0 *kafka.UntagResourceInput) (*request.Request, *kafka.UntagResourceOutput)
UntagResourceRequest mocks base method
func (*MockKafkaAPI) UntagResourceWithContext ¶
func (m *MockKafkaAPI) UntagResourceWithContext(arg0 context.Context, arg1 *kafka.UntagResourceInput, arg2 ...request.Option) (*kafka.UntagResourceOutput, error)
UntagResourceWithContext mocks base method
func (*MockKafkaAPI) UpdateBrokerCount ¶
func (m *MockKafkaAPI) UpdateBrokerCount(arg0 *kafka.UpdateBrokerCountInput) (*kafka.UpdateBrokerCountOutput, error)
UpdateBrokerCount mocks base method
func (*MockKafkaAPI) UpdateBrokerCountRequest ¶
func (m *MockKafkaAPI) UpdateBrokerCountRequest(arg0 *kafka.UpdateBrokerCountInput) (*request.Request, *kafka.UpdateBrokerCountOutput)
UpdateBrokerCountRequest mocks base method
func (*MockKafkaAPI) UpdateBrokerCountWithContext ¶
func (m *MockKafkaAPI) UpdateBrokerCountWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerCountInput, arg2 ...request.Option) (*kafka.UpdateBrokerCountOutput, error)
UpdateBrokerCountWithContext mocks base method
func (*MockKafkaAPI) UpdateBrokerStorage ¶
func (m *MockKafkaAPI) UpdateBrokerStorage(arg0 *kafka.UpdateBrokerStorageInput) (*kafka.UpdateBrokerStorageOutput, error)
UpdateBrokerStorage mocks base method
func (*MockKafkaAPI) UpdateBrokerStorageRequest ¶
func (m *MockKafkaAPI) UpdateBrokerStorageRequest(arg0 *kafka.UpdateBrokerStorageInput) (*request.Request, *kafka.UpdateBrokerStorageOutput)
UpdateBrokerStorageRequest mocks base method
func (*MockKafkaAPI) UpdateBrokerStorageWithContext ¶
func (m *MockKafkaAPI) UpdateBrokerStorageWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerStorageInput, arg2 ...request.Option) (*kafka.UpdateBrokerStorageOutput, error)
UpdateBrokerStorageWithContext mocks base method
func (*MockKafkaAPI) UpdateBrokerType ¶
func (m *MockKafkaAPI) UpdateBrokerType(arg0 *kafka.UpdateBrokerTypeInput) (*kafka.UpdateBrokerTypeOutput, error)
UpdateBrokerType mocks base method
func (*MockKafkaAPI) UpdateBrokerTypeRequest ¶
func (m *MockKafkaAPI) UpdateBrokerTypeRequest(arg0 *kafka.UpdateBrokerTypeInput) (*request.Request, *kafka.UpdateBrokerTypeOutput)
UpdateBrokerTypeRequest mocks base method
func (*MockKafkaAPI) UpdateBrokerTypeWithContext ¶
func (m *MockKafkaAPI) UpdateBrokerTypeWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerTypeInput, arg2 ...request.Option) (*kafka.UpdateBrokerTypeOutput, error)
UpdateBrokerTypeWithContext mocks base method
func (*MockKafkaAPI) UpdateClusterConfiguration ¶
func (m *MockKafkaAPI) UpdateClusterConfiguration(arg0 *kafka.UpdateClusterConfigurationInput) (*kafka.UpdateClusterConfigurationOutput, error)
UpdateClusterConfiguration mocks base method
func (*MockKafkaAPI) UpdateClusterConfigurationRequest ¶
func (m *MockKafkaAPI) UpdateClusterConfigurationRequest(arg0 *kafka.UpdateClusterConfigurationInput) (*request.Request, *kafka.UpdateClusterConfigurationOutput)
UpdateClusterConfigurationRequest mocks base method
func (*MockKafkaAPI) UpdateClusterConfigurationWithContext ¶
func (m *MockKafkaAPI) UpdateClusterConfigurationWithContext(arg0 context.Context, arg1 *kafka.UpdateClusterConfigurationInput, arg2 ...request.Option) (*kafka.UpdateClusterConfigurationOutput, error)
UpdateClusterConfigurationWithContext mocks base method
func (*MockKafkaAPI) UpdateClusterKafkaVersion ¶
func (m *MockKafkaAPI) UpdateClusterKafkaVersion(arg0 *kafka.UpdateClusterKafkaVersionInput) (*kafka.UpdateClusterKafkaVersionOutput, error)
UpdateClusterKafkaVersion mocks base method
func (*MockKafkaAPI) UpdateClusterKafkaVersionRequest ¶
func (m *MockKafkaAPI) UpdateClusterKafkaVersionRequest(arg0 *kafka.UpdateClusterKafkaVersionInput) (*request.Request, *kafka.UpdateClusterKafkaVersionOutput)
UpdateClusterKafkaVersionRequest mocks base method
func (*MockKafkaAPI) UpdateClusterKafkaVersionWithContext ¶
func (m *MockKafkaAPI) UpdateClusterKafkaVersionWithContext(arg0 context.Context, arg1 *kafka.UpdateClusterKafkaVersionInput, arg2 ...request.Option) (*kafka.UpdateClusterKafkaVersionOutput, error)
UpdateClusterKafkaVersionWithContext mocks base method
func (*MockKafkaAPI) UpdateConfiguration ¶
func (m *MockKafkaAPI) UpdateConfiguration(arg0 *kafka.UpdateConfigurationInput) (*kafka.UpdateConfigurationOutput, error)
UpdateConfiguration mocks base method
func (*MockKafkaAPI) UpdateConfigurationRequest ¶
func (m *MockKafkaAPI) UpdateConfigurationRequest(arg0 *kafka.UpdateConfigurationInput) (*request.Request, *kafka.UpdateConfigurationOutput)
UpdateConfigurationRequest mocks base method
func (*MockKafkaAPI) UpdateConfigurationWithContext ¶
func (m *MockKafkaAPI) UpdateConfigurationWithContext(arg0 context.Context, arg1 *kafka.UpdateConfigurationInput, arg2 ...request.Option) (*kafka.UpdateConfigurationOutput, error)
UpdateConfigurationWithContext mocks base method
func (*MockKafkaAPI) UpdateMonitoring ¶
func (m *MockKafkaAPI) UpdateMonitoring(arg0 *kafka.UpdateMonitoringInput) (*kafka.UpdateMonitoringOutput, error)
UpdateMonitoring mocks base method
func (*MockKafkaAPI) UpdateMonitoringRequest ¶
func (m *MockKafkaAPI) UpdateMonitoringRequest(arg0 *kafka.UpdateMonitoringInput) (*request.Request, *kafka.UpdateMonitoringOutput)
UpdateMonitoringRequest mocks base method
func (*MockKafkaAPI) UpdateMonitoringWithContext ¶
func (m *MockKafkaAPI) UpdateMonitoringWithContext(arg0 context.Context, arg1 *kafka.UpdateMonitoringInput, arg2 ...request.Option) (*kafka.UpdateMonitoringOutput, error)
UpdateMonitoringWithContext mocks base method
type MockKafkaAPIMockRecorder ¶
type MockKafkaAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockKafkaAPIMockRecorder is the mock recorder for MockKafkaAPI
func (*MockKafkaAPIMockRecorder) BatchAssociateScramSecret ¶
func (mr *MockKafkaAPIMockRecorder) BatchAssociateScramSecret(arg0 interface{}) *gomock.Call
BatchAssociateScramSecret indicates an expected call of BatchAssociateScramSecret
func (*MockKafkaAPIMockRecorder) BatchAssociateScramSecretRequest ¶
func (mr *MockKafkaAPIMockRecorder) BatchAssociateScramSecretRequest(arg0 interface{}) *gomock.Call
BatchAssociateScramSecretRequest indicates an expected call of BatchAssociateScramSecretRequest
func (*MockKafkaAPIMockRecorder) BatchAssociateScramSecretWithContext ¶
func (mr *MockKafkaAPIMockRecorder) BatchAssociateScramSecretWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
BatchAssociateScramSecretWithContext indicates an expected call of BatchAssociateScramSecretWithContext
func (*MockKafkaAPIMockRecorder) BatchDisassociateScramSecret ¶
func (mr *MockKafkaAPIMockRecorder) BatchDisassociateScramSecret(arg0 interface{}) *gomock.Call
BatchDisassociateScramSecret indicates an expected call of BatchDisassociateScramSecret
func (*MockKafkaAPIMockRecorder) BatchDisassociateScramSecretRequest ¶
func (mr *MockKafkaAPIMockRecorder) BatchDisassociateScramSecretRequest(arg0 interface{}) *gomock.Call
BatchDisassociateScramSecretRequest indicates an expected call of BatchDisassociateScramSecretRequest
func (*MockKafkaAPIMockRecorder) BatchDisassociateScramSecretWithContext ¶
func (mr *MockKafkaAPIMockRecorder) BatchDisassociateScramSecretWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
BatchDisassociateScramSecretWithContext indicates an expected call of BatchDisassociateScramSecretWithContext
func (*MockKafkaAPIMockRecorder) CreateCluster ¶
func (mr *MockKafkaAPIMockRecorder) CreateCluster(arg0 interface{}) *gomock.Call
CreateCluster indicates an expected call of CreateCluster
func (*MockKafkaAPIMockRecorder) CreateClusterRequest ¶
func (mr *MockKafkaAPIMockRecorder) CreateClusterRequest(arg0 interface{}) *gomock.Call
CreateClusterRequest indicates an expected call of CreateClusterRequest
func (*MockKafkaAPIMockRecorder) CreateClusterWithContext ¶
func (mr *MockKafkaAPIMockRecorder) CreateClusterWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateClusterWithContext indicates an expected call of CreateClusterWithContext
func (*MockKafkaAPIMockRecorder) CreateConfiguration ¶
func (mr *MockKafkaAPIMockRecorder) CreateConfiguration(arg0 interface{}) *gomock.Call
CreateConfiguration indicates an expected call of CreateConfiguration
func (*MockKafkaAPIMockRecorder) CreateConfigurationRequest ¶
func (mr *MockKafkaAPIMockRecorder) CreateConfigurationRequest(arg0 interface{}) *gomock.Call
CreateConfigurationRequest indicates an expected call of CreateConfigurationRequest
func (*MockKafkaAPIMockRecorder) CreateConfigurationWithContext ¶
func (mr *MockKafkaAPIMockRecorder) CreateConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateConfigurationWithContext indicates an expected call of CreateConfigurationWithContext
func (*MockKafkaAPIMockRecorder) DeleteCluster ¶
func (mr *MockKafkaAPIMockRecorder) DeleteCluster(arg0 interface{}) *gomock.Call
DeleteCluster indicates an expected call of DeleteCluster
func (*MockKafkaAPIMockRecorder) DeleteClusterRequest ¶
func (mr *MockKafkaAPIMockRecorder) DeleteClusterRequest(arg0 interface{}) *gomock.Call
DeleteClusterRequest indicates an expected call of DeleteClusterRequest
func (*MockKafkaAPIMockRecorder) DeleteClusterWithContext ¶
func (mr *MockKafkaAPIMockRecorder) DeleteClusterWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteClusterWithContext indicates an expected call of DeleteClusterWithContext
func (*MockKafkaAPIMockRecorder) DeleteConfiguration ¶
func (mr *MockKafkaAPIMockRecorder) DeleteConfiguration(arg0 interface{}) *gomock.Call
DeleteConfiguration indicates an expected call of DeleteConfiguration
func (*MockKafkaAPIMockRecorder) DeleteConfigurationRequest ¶
func (mr *MockKafkaAPIMockRecorder) DeleteConfigurationRequest(arg0 interface{}) *gomock.Call
DeleteConfigurationRequest indicates an expected call of DeleteConfigurationRequest
func (*MockKafkaAPIMockRecorder) DeleteConfigurationWithContext ¶
func (mr *MockKafkaAPIMockRecorder) DeleteConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteConfigurationWithContext indicates an expected call of DeleteConfigurationWithContext
func (*MockKafkaAPIMockRecorder) DescribeCluster ¶
func (mr *MockKafkaAPIMockRecorder) DescribeCluster(arg0 interface{}) *gomock.Call
DescribeCluster indicates an expected call of DescribeCluster
func (*MockKafkaAPIMockRecorder) DescribeClusterOperation ¶
func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperation(arg0 interface{}) *gomock.Call
DescribeClusterOperation indicates an expected call of DescribeClusterOperation
func (*MockKafkaAPIMockRecorder) DescribeClusterOperationRequest ¶
func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationRequest(arg0 interface{}) *gomock.Call
DescribeClusterOperationRequest indicates an expected call of DescribeClusterOperationRequest
func (*MockKafkaAPIMockRecorder) DescribeClusterOperationWithContext ¶
func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeClusterOperationWithContext indicates an expected call of DescribeClusterOperationWithContext
func (*MockKafkaAPIMockRecorder) DescribeClusterRequest ¶
func (mr *MockKafkaAPIMockRecorder) DescribeClusterRequest(arg0 interface{}) *gomock.Call
DescribeClusterRequest indicates an expected call of DescribeClusterRequest
func (*MockKafkaAPIMockRecorder) DescribeClusterWithContext ¶
func (mr *MockKafkaAPIMockRecorder) DescribeClusterWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeClusterWithContext indicates an expected call of DescribeClusterWithContext
func (*MockKafkaAPIMockRecorder) DescribeConfiguration ¶
func (mr *MockKafkaAPIMockRecorder) DescribeConfiguration(arg0 interface{}) *gomock.Call
DescribeConfiguration indicates an expected call of DescribeConfiguration
func (*MockKafkaAPIMockRecorder) DescribeConfigurationRequest ¶
func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationRequest(arg0 interface{}) *gomock.Call
DescribeConfigurationRequest indicates an expected call of DescribeConfigurationRequest
func (*MockKafkaAPIMockRecorder) DescribeConfigurationRevision ¶
func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationRevision(arg0 interface{}) *gomock.Call
DescribeConfigurationRevision indicates an expected call of DescribeConfigurationRevision
func (*MockKafkaAPIMockRecorder) DescribeConfigurationRevisionRequest ¶
func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationRevisionRequest(arg0 interface{}) *gomock.Call
DescribeConfigurationRevisionRequest indicates an expected call of DescribeConfigurationRevisionRequest
func (*MockKafkaAPIMockRecorder) DescribeConfigurationRevisionWithContext ¶
func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationRevisionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeConfigurationRevisionWithContext indicates an expected call of DescribeConfigurationRevisionWithContext
func (*MockKafkaAPIMockRecorder) DescribeConfigurationWithContext ¶
func (mr *MockKafkaAPIMockRecorder) DescribeConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeConfigurationWithContext indicates an expected call of DescribeConfigurationWithContext
func (*MockKafkaAPIMockRecorder) GetBootstrapBrokers ¶
func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokers(arg0 interface{}) *gomock.Call
GetBootstrapBrokers indicates an expected call of GetBootstrapBrokers
func (*MockKafkaAPIMockRecorder) GetBootstrapBrokersRequest ¶
func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokersRequest(arg0 interface{}) *gomock.Call
GetBootstrapBrokersRequest indicates an expected call of GetBootstrapBrokersRequest
func (*MockKafkaAPIMockRecorder) GetBootstrapBrokersWithContext ¶
func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokersWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetBootstrapBrokersWithContext indicates an expected call of GetBootstrapBrokersWithContext
func (*MockKafkaAPIMockRecorder) GetCompatibleKafkaVersions ¶
func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersions(arg0 interface{}) *gomock.Call
GetCompatibleKafkaVersions indicates an expected call of GetCompatibleKafkaVersions
func (*MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsRequest ¶
func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsRequest(arg0 interface{}) *gomock.Call
GetCompatibleKafkaVersionsRequest indicates an expected call of GetCompatibleKafkaVersionsRequest
func (*MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsWithContext ¶
func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetCompatibleKafkaVersionsWithContext indicates an expected call of GetCompatibleKafkaVersionsWithContext
func (*MockKafkaAPIMockRecorder) ListClusterOperations ¶
func (mr *MockKafkaAPIMockRecorder) ListClusterOperations(arg0 interface{}) *gomock.Call
ListClusterOperations indicates an expected call of ListClusterOperations
func (*MockKafkaAPIMockRecorder) ListClusterOperationsPages ¶
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsPages(arg0, arg1 interface{}) *gomock.Call
ListClusterOperationsPages indicates an expected call of ListClusterOperationsPages
func (*MockKafkaAPIMockRecorder) ListClusterOperationsPagesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListClusterOperationsPagesWithContext indicates an expected call of ListClusterOperationsPagesWithContext
func (*MockKafkaAPIMockRecorder) ListClusterOperationsRequest ¶
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsRequest(arg0 interface{}) *gomock.Call
ListClusterOperationsRequest indicates an expected call of ListClusterOperationsRequest
func (*MockKafkaAPIMockRecorder) ListClusterOperationsWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListClusterOperationsWithContext indicates an expected call of ListClusterOperationsWithContext
func (*MockKafkaAPIMockRecorder) ListClusters ¶
func (mr *MockKafkaAPIMockRecorder) ListClusters(arg0 interface{}) *gomock.Call
ListClusters indicates an expected call of ListClusters
func (*MockKafkaAPIMockRecorder) ListClustersPages ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersPages(arg0, arg1 interface{}) *gomock.Call
ListClustersPages indicates an expected call of ListClustersPages
func (*MockKafkaAPIMockRecorder) ListClustersPagesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListClustersPagesWithContext indicates an expected call of ListClustersPagesWithContext
func (*MockKafkaAPIMockRecorder) ListClustersRequest ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersRequest(arg0 interface{}) *gomock.Call
ListClustersRequest indicates an expected call of ListClustersRequest
func (*MockKafkaAPIMockRecorder) ListClustersWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListClustersWithContext indicates an expected call of ListClustersWithContext
func (*MockKafkaAPIMockRecorder) ListConfigurationRevisions ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisions(arg0 interface{}) *gomock.Call
ListConfigurationRevisions indicates an expected call of ListConfigurationRevisions
func (*MockKafkaAPIMockRecorder) ListConfigurationRevisionsPages ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisionsPages(arg0, arg1 interface{}) *gomock.Call
ListConfigurationRevisionsPages indicates an expected call of ListConfigurationRevisionsPages
func (*MockKafkaAPIMockRecorder) ListConfigurationRevisionsPagesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisionsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListConfigurationRevisionsPagesWithContext indicates an expected call of ListConfigurationRevisionsPagesWithContext
func (*MockKafkaAPIMockRecorder) ListConfigurationRevisionsRequest ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisionsRequest(arg0 interface{}) *gomock.Call
ListConfigurationRevisionsRequest indicates an expected call of ListConfigurationRevisionsRequest
func (*MockKafkaAPIMockRecorder) ListConfigurationRevisionsWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationRevisionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListConfigurationRevisionsWithContext indicates an expected call of ListConfigurationRevisionsWithContext
func (*MockKafkaAPIMockRecorder) ListConfigurations ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurations(arg0 interface{}) *gomock.Call
ListConfigurations indicates an expected call of ListConfigurations
func (*MockKafkaAPIMockRecorder) ListConfigurationsPages ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationsPages(arg0, arg1 interface{}) *gomock.Call
ListConfigurationsPages indicates an expected call of ListConfigurationsPages
func (*MockKafkaAPIMockRecorder) ListConfigurationsPagesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListConfigurationsPagesWithContext indicates an expected call of ListConfigurationsPagesWithContext
func (*MockKafkaAPIMockRecorder) ListConfigurationsRequest ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationsRequest(arg0 interface{}) *gomock.Call
ListConfigurationsRequest indicates an expected call of ListConfigurationsRequest
func (*MockKafkaAPIMockRecorder) ListConfigurationsWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListConfigurationsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListConfigurationsWithContext indicates an expected call of ListConfigurationsWithContext
func (*MockKafkaAPIMockRecorder) ListKafkaVersions ¶
func (mr *MockKafkaAPIMockRecorder) ListKafkaVersions(arg0 interface{}) *gomock.Call
ListKafkaVersions indicates an expected call of ListKafkaVersions
func (*MockKafkaAPIMockRecorder) ListKafkaVersionsPages ¶
func (mr *MockKafkaAPIMockRecorder) ListKafkaVersionsPages(arg0, arg1 interface{}) *gomock.Call
ListKafkaVersionsPages indicates an expected call of ListKafkaVersionsPages
func (*MockKafkaAPIMockRecorder) ListKafkaVersionsPagesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListKafkaVersionsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListKafkaVersionsPagesWithContext indicates an expected call of ListKafkaVersionsPagesWithContext
func (*MockKafkaAPIMockRecorder) ListKafkaVersionsRequest ¶
func (mr *MockKafkaAPIMockRecorder) ListKafkaVersionsRequest(arg0 interface{}) *gomock.Call
ListKafkaVersionsRequest indicates an expected call of ListKafkaVersionsRequest
func (*MockKafkaAPIMockRecorder) ListKafkaVersionsWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListKafkaVersionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListKafkaVersionsWithContext indicates an expected call of ListKafkaVersionsWithContext
func (*MockKafkaAPIMockRecorder) ListNodes ¶
func (mr *MockKafkaAPIMockRecorder) ListNodes(arg0 interface{}) *gomock.Call
ListNodes indicates an expected call of ListNodes
func (*MockKafkaAPIMockRecorder) ListNodesPages ¶
func (mr *MockKafkaAPIMockRecorder) ListNodesPages(arg0, arg1 interface{}) *gomock.Call
ListNodesPages indicates an expected call of ListNodesPages
func (*MockKafkaAPIMockRecorder) ListNodesPagesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListNodesPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListNodesPagesWithContext indicates an expected call of ListNodesPagesWithContext
func (*MockKafkaAPIMockRecorder) ListNodesRequest ¶
func (mr *MockKafkaAPIMockRecorder) ListNodesRequest(arg0 interface{}) *gomock.Call
ListNodesRequest indicates an expected call of ListNodesRequest
func (*MockKafkaAPIMockRecorder) ListNodesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListNodesWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListNodesWithContext indicates an expected call of ListNodesWithContext
func (*MockKafkaAPIMockRecorder) ListScramSecrets ¶
func (mr *MockKafkaAPIMockRecorder) ListScramSecrets(arg0 interface{}) *gomock.Call
ListScramSecrets indicates an expected call of ListScramSecrets
func (*MockKafkaAPIMockRecorder) ListScramSecretsPages ¶
func (mr *MockKafkaAPIMockRecorder) ListScramSecretsPages(arg0, arg1 interface{}) *gomock.Call
ListScramSecretsPages indicates an expected call of ListScramSecretsPages
func (*MockKafkaAPIMockRecorder) ListScramSecretsPagesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListScramSecretsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListScramSecretsPagesWithContext indicates an expected call of ListScramSecretsPagesWithContext
func (*MockKafkaAPIMockRecorder) ListScramSecretsRequest ¶
func (mr *MockKafkaAPIMockRecorder) ListScramSecretsRequest(arg0 interface{}) *gomock.Call
ListScramSecretsRequest indicates an expected call of ListScramSecretsRequest
func (*MockKafkaAPIMockRecorder) ListScramSecretsWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListScramSecretsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListScramSecretsWithContext indicates an expected call of ListScramSecretsWithContext
func (*MockKafkaAPIMockRecorder) ListTagsForResource ¶
func (mr *MockKafkaAPIMockRecorder) ListTagsForResource(arg0 interface{}) *gomock.Call
ListTagsForResource indicates an expected call of ListTagsForResource
func (*MockKafkaAPIMockRecorder) ListTagsForResourceRequest ¶
func (mr *MockKafkaAPIMockRecorder) ListTagsForResourceRequest(arg0 interface{}) *gomock.Call
ListTagsForResourceRequest indicates an expected call of ListTagsForResourceRequest
func (*MockKafkaAPIMockRecorder) ListTagsForResourceWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListTagsForResourceWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListTagsForResourceWithContext indicates an expected call of ListTagsForResourceWithContext
func (*MockKafkaAPIMockRecorder) RebootBroker ¶
func (mr *MockKafkaAPIMockRecorder) RebootBroker(arg0 interface{}) *gomock.Call
RebootBroker indicates an expected call of RebootBroker
func (*MockKafkaAPIMockRecorder) RebootBrokerRequest ¶
func (mr *MockKafkaAPIMockRecorder) RebootBrokerRequest(arg0 interface{}) *gomock.Call
RebootBrokerRequest indicates an expected call of RebootBrokerRequest
func (*MockKafkaAPIMockRecorder) RebootBrokerWithContext ¶
func (mr *MockKafkaAPIMockRecorder) RebootBrokerWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RebootBrokerWithContext indicates an expected call of RebootBrokerWithContext
func (*MockKafkaAPIMockRecorder) TagResource ¶
func (mr *MockKafkaAPIMockRecorder) TagResource(arg0 interface{}) *gomock.Call
TagResource indicates an expected call of TagResource
func (*MockKafkaAPIMockRecorder) TagResourceRequest ¶
func (mr *MockKafkaAPIMockRecorder) TagResourceRequest(arg0 interface{}) *gomock.Call
TagResourceRequest indicates an expected call of TagResourceRequest
func (*MockKafkaAPIMockRecorder) TagResourceWithContext ¶
func (mr *MockKafkaAPIMockRecorder) TagResourceWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
TagResourceWithContext indicates an expected call of TagResourceWithContext
func (*MockKafkaAPIMockRecorder) UntagResource ¶
func (mr *MockKafkaAPIMockRecorder) UntagResource(arg0 interface{}) *gomock.Call
UntagResource indicates an expected call of UntagResource
func (*MockKafkaAPIMockRecorder) UntagResourceRequest ¶
func (mr *MockKafkaAPIMockRecorder) UntagResourceRequest(arg0 interface{}) *gomock.Call
UntagResourceRequest indicates an expected call of UntagResourceRequest
func (*MockKafkaAPIMockRecorder) UntagResourceWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UntagResourceWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UntagResourceWithContext indicates an expected call of UntagResourceWithContext
func (*MockKafkaAPIMockRecorder) UpdateBrokerCount ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCount(arg0 interface{}) *gomock.Call
UpdateBrokerCount indicates an expected call of UpdateBrokerCount
func (*MockKafkaAPIMockRecorder) UpdateBrokerCountRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCountRequest(arg0 interface{}) *gomock.Call
UpdateBrokerCountRequest indicates an expected call of UpdateBrokerCountRequest
func (*MockKafkaAPIMockRecorder) UpdateBrokerCountWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCountWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateBrokerCountWithContext indicates an expected call of UpdateBrokerCountWithContext
func (*MockKafkaAPIMockRecorder) UpdateBrokerStorage ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorage(arg0 interface{}) *gomock.Call
UpdateBrokerStorage indicates an expected call of UpdateBrokerStorage
func (*MockKafkaAPIMockRecorder) UpdateBrokerStorageRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorageRequest(arg0 interface{}) *gomock.Call
UpdateBrokerStorageRequest indicates an expected call of UpdateBrokerStorageRequest
func (*MockKafkaAPIMockRecorder) UpdateBrokerStorageWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorageWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateBrokerStorageWithContext indicates an expected call of UpdateBrokerStorageWithContext
func (*MockKafkaAPIMockRecorder) UpdateBrokerType ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerType(arg0 interface{}) *gomock.Call
UpdateBrokerType indicates an expected call of UpdateBrokerType
func (*MockKafkaAPIMockRecorder) UpdateBrokerTypeRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerTypeRequest(arg0 interface{}) *gomock.Call
UpdateBrokerTypeRequest indicates an expected call of UpdateBrokerTypeRequest
func (*MockKafkaAPIMockRecorder) UpdateBrokerTypeWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateBrokerTypeWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateBrokerTypeWithContext indicates an expected call of UpdateBrokerTypeWithContext
func (*MockKafkaAPIMockRecorder) UpdateClusterConfiguration ¶
func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfiguration(arg0 interface{}) *gomock.Call
UpdateClusterConfiguration indicates an expected call of UpdateClusterConfiguration
func (*MockKafkaAPIMockRecorder) UpdateClusterConfigurationRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfigurationRequest(arg0 interface{}) *gomock.Call
UpdateClusterConfigurationRequest indicates an expected call of UpdateClusterConfigurationRequest
func (*MockKafkaAPIMockRecorder) UpdateClusterConfigurationWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateClusterConfigurationWithContext indicates an expected call of UpdateClusterConfigurationWithContext
func (*MockKafkaAPIMockRecorder) UpdateClusterKafkaVersion ¶
func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersion(arg0 interface{}) *gomock.Call
UpdateClusterKafkaVersion indicates an expected call of UpdateClusterKafkaVersion
func (*MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionRequest(arg0 interface{}) *gomock.Call
UpdateClusterKafkaVersionRequest indicates an expected call of UpdateClusterKafkaVersionRequest
func (*MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateClusterKafkaVersionWithContext indicates an expected call of UpdateClusterKafkaVersionWithContext
func (*MockKafkaAPIMockRecorder) UpdateConfiguration ¶
func (mr *MockKafkaAPIMockRecorder) UpdateConfiguration(arg0 interface{}) *gomock.Call
UpdateConfiguration indicates an expected call of UpdateConfiguration
func (*MockKafkaAPIMockRecorder) UpdateConfigurationRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateConfigurationRequest(arg0 interface{}) *gomock.Call
UpdateConfigurationRequest indicates an expected call of UpdateConfigurationRequest
func (*MockKafkaAPIMockRecorder) UpdateConfigurationWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateConfigurationWithContext indicates an expected call of UpdateConfigurationWithContext
func (*MockKafkaAPIMockRecorder) UpdateMonitoring ¶
func (mr *MockKafkaAPIMockRecorder) UpdateMonitoring(arg0 interface{}) *gomock.Call
UpdateMonitoring indicates an expected call of UpdateMonitoring
func (*MockKafkaAPIMockRecorder) UpdateMonitoringRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateMonitoringRequest(arg0 interface{}) *gomock.Call
UpdateMonitoringRequest indicates an expected call of UpdateMonitoringRequest
func (*MockKafkaAPIMockRecorder) UpdateMonitoringWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateMonitoringWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateMonitoringWithContext indicates an expected call of UpdateMonitoringWithContext