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) CreateClusterV2(arg0 *kafka.CreateClusterV2Input) (*kafka.CreateClusterV2Output, error)
- func (m *MockKafkaAPI) CreateClusterV2Request(arg0 *kafka.CreateClusterV2Input) (*request.Request, *kafka.CreateClusterV2Output)
- func (m *MockKafkaAPI) CreateClusterV2WithContext(arg0 context.Context, arg1 *kafka.CreateClusterV2Input, arg2 ...request.Option) (*kafka.CreateClusterV2Output, error)
- 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) CreateVpcConnection(arg0 *kafka.CreateVpcConnectionInput) (*kafka.CreateVpcConnectionOutput, error)
- func (m *MockKafkaAPI) CreateVpcConnectionRequest(arg0 *kafka.CreateVpcConnectionInput) (*request.Request, *kafka.CreateVpcConnectionOutput)
- func (m *MockKafkaAPI) CreateVpcConnectionWithContext(arg0 context.Context, arg1 *kafka.CreateVpcConnectionInput, ...) (*kafka.CreateVpcConnectionOutput, error)
- func (m *MockKafkaAPI) DeleteCluster(arg0 *kafka.DeleteClusterInput) (*kafka.DeleteClusterOutput, error)
- func (m *MockKafkaAPI) DeleteClusterPolicy(arg0 *kafka.DeleteClusterPolicyInput) (*kafka.DeleteClusterPolicyOutput, error)
- func (m *MockKafkaAPI) DeleteClusterPolicyRequest(arg0 *kafka.DeleteClusterPolicyInput) (*request.Request, *kafka.DeleteClusterPolicyOutput)
- func (m *MockKafkaAPI) DeleteClusterPolicyWithContext(arg0 context.Context, arg1 *kafka.DeleteClusterPolicyInput, ...) (*kafka.DeleteClusterPolicyOutput, 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) DeleteVpcConnection(arg0 *kafka.DeleteVpcConnectionInput) (*kafka.DeleteVpcConnectionOutput, error)
- func (m *MockKafkaAPI) DeleteVpcConnectionRequest(arg0 *kafka.DeleteVpcConnectionInput) (*request.Request, *kafka.DeleteVpcConnectionOutput)
- func (m *MockKafkaAPI) DeleteVpcConnectionWithContext(arg0 context.Context, arg1 *kafka.DeleteVpcConnectionInput, ...) (*kafka.DeleteVpcConnectionOutput, 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) DescribeClusterOperationV2(arg0 *kafka.DescribeClusterOperationV2Input) (*kafka.DescribeClusterOperationV2Output, error)
- func (m *MockKafkaAPI) DescribeClusterOperationV2Request(arg0 *kafka.DescribeClusterOperationV2Input) (*request.Request, *kafka.DescribeClusterOperationV2Output)
- func (m *MockKafkaAPI) DescribeClusterOperationV2WithContext(arg0 context.Context, arg1 *kafka.DescribeClusterOperationV2Input, ...) (*kafka.DescribeClusterOperationV2Output, error)
- 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) DescribeClusterV2(arg0 *kafka.DescribeClusterV2Input) (*kafka.DescribeClusterV2Output, error)
- func (m *MockKafkaAPI) DescribeClusterV2Request(arg0 *kafka.DescribeClusterV2Input) (*request.Request, *kafka.DescribeClusterV2Output)
- func (m *MockKafkaAPI) DescribeClusterV2WithContext(arg0 context.Context, arg1 *kafka.DescribeClusterV2Input, ...) (*kafka.DescribeClusterV2Output, error)
- 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) DescribeVpcConnection(arg0 *kafka.DescribeVpcConnectionInput) (*kafka.DescribeVpcConnectionOutput, error)
- func (m *MockKafkaAPI) DescribeVpcConnectionRequest(arg0 *kafka.DescribeVpcConnectionInput) (*request.Request, *kafka.DescribeVpcConnectionOutput)
- func (m *MockKafkaAPI) DescribeVpcConnectionWithContext(arg0 context.Context, arg1 *kafka.DescribeVpcConnectionInput, ...) (*kafka.DescribeVpcConnectionOutput, 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) GetClusterPolicy(arg0 *kafka.GetClusterPolicyInput) (*kafka.GetClusterPolicyOutput, error)
- func (m *MockKafkaAPI) GetClusterPolicyRequest(arg0 *kafka.GetClusterPolicyInput) (*request.Request, *kafka.GetClusterPolicyOutput)
- func (m *MockKafkaAPI) GetClusterPolicyWithContext(arg0 context.Context, arg1 *kafka.GetClusterPolicyInput, ...) (*kafka.GetClusterPolicyOutput, 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) ListClientVpcConnections(arg0 *kafka.ListClientVpcConnectionsInput) (*kafka.ListClientVpcConnectionsOutput, error)
- func (m *MockKafkaAPI) ListClientVpcConnectionsPages(arg0 *kafka.ListClientVpcConnectionsInput, ...) error
- func (m *MockKafkaAPI) ListClientVpcConnectionsPagesWithContext(arg0 context.Context, arg1 *kafka.ListClientVpcConnectionsInput, ...) error
- func (m *MockKafkaAPI) ListClientVpcConnectionsRequest(arg0 *kafka.ListClientVpcConnectionsInput) (*request.Request, *kafka.ListClientVpcConnectionsOutput)
- func (m *MockKafkaAPI) ListClientVpcConnectionsWithContext(arg0 context.Context, arg1 *kafka.ListClientVpcConnectionsInput, ...) (*kafka.ListClientVpcConnectionsOutput, 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) ListClusterOperationsV2(arg0 *kafka.ListClusterOperationsV2Input) (*kafka.ListClusterOperationsV2Output, error)
- func (m *MockKafkaAPI) ListClusterOperationsV2Pages(arg0 *kafka.ListClusterOperationsV2Input, ...) error
- func (m *MockKafkaAPI) ListClusterOperationsV2PagesWithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsV2Input, ...) error
- func (m *MockKafkaAPI) ListClusterOperationsV2Request(arg0 *kafka.ListClusterOperationsV2Input) (*request.Request, *kafka.ListClusterOperationsV2Output)
- func (m *MockKafkaAPI) ListClusterOperationsV2WithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsV2Input, ...) (*kafka.ListClusterOperationsV2Output, error)
- 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) ListClustersV2(arg0 *kafka.ListClustersV2Input) (*kafka.ListClustersV2Output, error)
- func (m *MockKafkaAPI) ListClustersV2Pages(arg0 *kafka.ListClustersV2Input, ...) error
- func (m *MockKafkaAPI) ListClustersV2PagesWithContext(arg0 context.Context, arg1 *kafka.ListClustersV2Input, ...) error
- func (m *MockKafkaAPI) ListClustersV2Request(arg0 *kafka.ListClustersV2Input) (*request.Request, *kafka.ListClustersV2Output)
- func (m *MockKafkaAPI) ListClustersV2WithContext(arg0 context.Context, arg1 *kafka.ListClustersV2Input, arg2 ...request.Option) (*kafka.ListClustersV2Output, error)
- 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) ListVpcConnections(arg0 *kafka.ListVpcConnectionsInput) (*kafka.ListVpcConnectionsOutput, error)
- func (m *MockKafkaAPI) ListVpcConnectionsPages(arg0 *kafka.ListVpcConnectionsInput, ...) error
- func (m *MockKafkaAPI) ListVpcConnectionsPagesWithContext(arg0 context.Context, arg1 *kafka.ListVpcConnectionsInput, ...) error
- func (m *MockKafkaAPI) ListVpcConnectionsRequest(arg0 *kafka.ListVpcConnectionsInput) (*request.Request, *kafka.ListVpcConnectionsOutput)
- func (m *MockKafkaAPI) ListVpcConnectionsWithContext(arg0 context.Context, arg1 *kafka.ListVpcConnectionsInput, ...) (*kafka.ListVpcConnectionsOutput, error)
- func (m *MockKafkaAPI) PutClusterPolicy(arg0 *kafka.PutClusterPolicyInput) (*kafka.PutClusterPolicyOutput, error)
- func (m *MockKafkaAPI) PutClusterPolicyRequest(arg0 *kafka.PutClusterPolicyInput) (*request.Request, *kafka.PutClusterPolicyOutput)
- func (m *MockKafkaAPI) PutClusterPolicyWithContext(arg0 context.Context, arg1 *kafka.PutClusterPolicyInput, ...) (*kafka.PutClusterPolicyOutput, 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) RejectClientVpcConnection(arg0 *kafka.RejectClientVpcConnectionInput) (*kafka.RejectClientVpcConnectionOutput, error)
- func (m *MockKafkaAPI) RejectClientVpcConnectionRequest(arg0 *kafka.RejectClientVpcConnectionInput) (*request.Request, *kafka.RejectClientVpcConnectionOutput)
- func (m *MockKafkaAPI) RejectClientVpcConnectionWithContext(arg0 context.Context, arg1 *kafka.RejectClientVpcConnectionInput, ...) (*kafka.RejectClientVpcConnectionOutput, 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) UpdateConnectivity(arg0 *kafka.UpdateConnectivityInput) (*kafka.UpdateConnectivityOutput, error)
- func (m *MockKafkaAPI) UpdateConnectivityRequest(arg0 *kafka.UpdateConnectivityInput) (*request.Request, *kafka.UpdateConnectivityOutput)
- func (m *MockKafkaAPI) UpdateConnectivityWithContext(arg0 context.Context, arg1 *kafka.UpdateConnectivityInput, ...) (*kafka.UpdateConnectivityOutput, 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)
- func (m *MockKafkaAPI) UpdateSecurity(arg0 *kafka.UpdateSecurityInput) (*kafka.UpdateSecurityOutput, error)
- func (m *MockKafkaAPI) UpdateSecurityRequest(arg0 *kafka.UpdateSecurityInput) (*request.Request, *kafka.UpdateSecurityOutput)
- func (m *MockKafkaAPI) UpdateSecurityWithContext(arg0 context.Context, arg1 *kafka.UpdateSecurityInput, arg2 ...request.Option) (*kafka.UpdateSecurityOutput, error)
- func (m *MockKafkaAPI) UpdateStorage(arg0 *kafka.UpdateStorageInput) (*kafka.UpdateStorageOutput, error)
- func (m *MockKafkaAPI) UpdateStorageRequest(arg0 *kafka.UpdateStorageInput) (*request.Request, *kafka.UpdateStorageOutput)
- func (m *MockKafkaAPI) UpdateStorageWithContext(arg0 context.Context, arg1 *kafka.UpdateStorageInput, arg2 ...request.Option) (*kafka.UpdateStorageOutput, 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) CreateClusterV2(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateClusterV2Request(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateClusterV2WithContext(arg0, arg1 interface{}, arg2 ...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) CreateVpcConnection(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateVpcConnectionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) CreateVpcConnectionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteCluster(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteClusterPolicy(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteClusterPolicyRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteClusterPolicyWithContext(arg0, arg1 interface{}, arg2 ...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) DeleteVpcConnection(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteVpcConnectionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DeleteVpcConnectionWithContext(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) DescribeClusterOperationV2(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationV2Request(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationV2WithContext(arg0, arg1 interface{}, arg2 ...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) DescribeClusterV2(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterV2Request(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeClusterV2WithContext(arg0, arg1 interface{}, arg2 ...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) DescribeVpcConnection(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeVpcConnectionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) DescribeVpcConnectionWithContext(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) GetClusterPolicy(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) GetClusterPolicyRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) GetClusterPolicyWithContext(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) ListClientVpcConnections(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnectionsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnectionsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnectionsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnectionsWithContext(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) ListClusterOperationsV2(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2Pages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2PagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2Request(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2WithContext(arg0, arg1 interface{}, arg2 ...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) ListClustersV2(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClustersV2Pages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClustersV2PagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClustersV2Request(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListClustersV2WithContext(arg0, arg1 interface{}, arg2 ...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) ListVpcConnections(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListVpcConnectionsPages(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListVpcConnectionsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListVpcConnectionsRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) ListVpcConnectionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) PutClusterPolicy(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) PutClusterPolicyRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) PutClusterPolicyWithContext(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) RejectClientVpcConnection(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) RejectClientVpcConnectionRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) RejectClientVpcConnectionWithContext(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) UpdateConnectivity(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateConnectivityRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateConnectivityWithContext(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
- func (mr *MockKafkaAPIMockRecorder) UpdateSecurity(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateSecurityRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateSecurityWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateStorage(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateStorageRequest(arg0 interface{}) *gomock.Call
- func (mr *MockKafkaAPIMockRecorder) UpdateStorageWithContext(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) CreateClusterV2 ¶
func (m *MockKafkaAPI) CreateClusterV2(arg0 *kafka.CreateClusterV2Input) (*kafka.CreateClusterV2Output, error)
CreateClusterV2 mocks base method
func (*MockKafkaAPI) CreateClusterV2Request ¶
func (m *MockKafkaAPI) CreateClusterV2Request(arg0 *kafka.CreateClusterV2Input) (*request.Request, *kafka.CreateClusterV2Output)
CreateClusterV2Request mocks base method
func (*MockKafkaAPI) CreateClusterV2WithContext ¶
func (m *MockKafkaAPI) CreateClusterV2WithContext(arg0 context.Context, arg1 *kafka.CreateClusterV2Input, arg2 ...request.Option) (*kafka.CreateClusterV2Output, error)
CreateClusterV2WithContext 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) CreateVpcConnection ¶ added in v1.44.252
func (m *MockKafkaAPI) CreateVpcConnection(arg0 *kafka.CreateVpcConnectionInput) (*kafka.CreateVpcConnectionOutput, error)
CreateVpcConnection mocks base method
func (*MockKafkaAPI) CreateVpcConnectionRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) CreateVpcConnectionRequest(arg0 *kafka.CreateVpcConnectionInput) (*request.Request, *kafka.CreateVpcConnectionOutput)
CreateVpcConnectionRequest mocks base method
func (*MockKafkaAPI) CreateVpcConnectionWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) CreateVpcConnectionWithContext(arg0 context.Context, arg1 *kafka.CreateVpcConnectionInput, arg2 ...request.Option) (*kafka.CreateVpcConnectionOutput, error)
CreateVpcConnectionWithContext mocks base method
func (*MockKafkaAPI) DeleteCluster ¶
func (m *MockKafkaAPI) DeleteCluster(arg0 *kafka.DeleteClusterInput) (*kafka.DeleteClusterOutput, error)
DeleteCluster mocks base method
func (*MockKafkaAPI) DeleteClusterPolicy ¶ added in v1.44.252
func (m *MockKafkaAPI) DeleteClusterPolicy(arg0 *kafka.DeleteClusterPolicyInput) (*kafka.DeleteClusterPolicyOutput, error)
DeleteClusterPolicy mocks base method
func (*MockKafkaAPI) DeleteClusterPolicyRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) DeleteClusterPolicyRequest(arg0 *kafka.DeleteClusterPolicyInput) (*request.Request, *kafka.DeleteClusterPolicyOutput)
DeleteClusterPolicyRequest mocks base method
func (*MockKafkaAPI) DeleteClusterPolicyWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) DeleteClusterPolicyWithContext(arg0 context.Context, arg1 *kafka.DeleteClusterPolicyInput, arg2 ...request.Option) (*kafka.DeleteClusterPolicyOutput, error)
DeleteClusterPolicyWithContext 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) DeleteVpcConnection ¶ added in v1.44.252
func (m *MockKafkaAPI) DeleteVpcConnection(arg0 *kafka.DeleteVpcConnectionInput) (*kafka.DeleteVpcConnectionOutput, error)
DeleteVpcConnection mocks base method
func (*MockKafkaAPI) DeleteVpcConnectionRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) DeleteVpcConnectionRequest(arg0 *kafka.DeleteVpcConnectionInput) (*request.Request, *kafka.DeleteVpcConnectionOutput)
DeleteVpcConnectionRequest mocks base method
func (*MockKafkaAPI) DeleteVpcConnectionWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) DeleteVpcConnectionWithContext(arg0 context.Context, arg1 *kafka.DeleteVpcConnectionInput, arg2 ...request.Option) (*kafka.DeleteVpcConnectionOutput, error)
DeleteVpcConnectionWithContext 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) DescribeClusterOperationV2 ¶ added in v1.44.312
func (m *MockKafkaAPI) DescribeClusterOperationV2(arg0 *kafka.DescribeClusterOperationV2Input) (*kafka.DescribeClusterOperationV2Output, error)
DescribeClusterOperationV2 mocks base method
func (*MockKafkaAPI) DescribeClusterOperationV2Request ¶ added in v1.44.312
func (m *MockKafkaAPI) DescribeClusterOperationV2Request(arg0 *kafka.DescribeClusterOperationV2Input) (*request.Request, *kafka.DescribeClusterOperationV2Output)
DescribeClusterOperationV2Request mocks base method
func (*MockKafkaAPI) DescribeClusterOperationV2WithContext ¶ added in v1.44.312
func (m *MockKafkaAPI) DescribeClusterOperationV2WithContext(arg0 context.Context, arg1 *kafka.DescribeClusterOperationV2Input, arg2 ...request.Option) (*kafka.DescribeClusterOperationV2Output, error)
DescribeClusterOperationV2WithContext 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) DescribeClusterV2 ¶
func (m *MockKafkaAPI) DescribeClusterV2(arg0 *kafka.DescribeClusterV2Input) (*kafka.DescribeClusterV2Output, error)
DescribeClusterV2 mocks base method
func (*MockKafkaAPI) DescribeClusterV2Request ¶
func (m *MockKafkaAPI) DescribeClusterV2Request(arg0 *kafka.DescribeClusterV2Input) (*request.Request, *kafka.DescribeClusterV2Output)
DescribeClusterV2Request mocks base method
func (*MockKafkaAPI) DescribeClusterV2WithContext ¶
func (m *MockKafkaAPI) DescribeClusterV2WithContext(arg0 context.Context, arg1 *kafka.DescribeClusterV2Input, arg2 ...request.Option) (*kafka.DescribeClusterV2Output, error)
DescribeClusterV2WithContext 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) DescribeVpcConnection ¶ added in v1.44.252
func (m *MockKafkaAPI) DescribeVpcConnection(arg0 *kafka.DescribeVpcConnectionInput) (*kafka.DescribeVpcConnectionOutput, error)
DescribeVpcConnection mocks base method
func (*MockKafkaAPI) DescribeVpcConnectionRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) DescribeVpcConnectionRequest(arg0 *kafka.DescribeVpcConnectionInput) (*request.Request, *kafka.DescribeVpcConnectionOutput)
DescribeVpcConnectionRequest mocks base method
func (*MockKafkaAPI) DescribeVpcConnectionWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) DescribeVpcConnectionWithContext(arg0 context.Context, arg1 *kafka.DescribeVpcConnectionInput, arg2 ...request.Option) (*kafka.DescribeVpcConnectionOutput, error)
DescribeVpcConnectionWithContext 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) GetClusterPolicy ¶ added in v1.44.252
func (m *MockKafkaAPI) GetClusterPolicy(arg0 *kafka.GetClusterPolicyInput) (*kafka.GetClusterPolicyOutput, error)
GetClusterPolicy mocks base method
func (*MockKafkaAPI) GetClusterPolicyRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) GetClusterPolicyRequest(arg0 *kafka.GetClusterPolicyInput) (*request.Request, *kafka.GetClusterPolicyOutput)
GetClusterPolicyRequest mocks base method
func (*MockKafkaAPI) GetClusterPolicyWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) GetClusterPolicyWithContext(arg0 context.Context, arg1 *kafka.GetClusterPolicyInput, arg2 ...request.Option) (*kafka.GetClusterPolicyOutput, error)
GetClusterPolicyWithContext 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) ListClientVpcConnections ¶ added in v1.44.252
func (m *MockKafkaAPI) ListClientVpcConnections(arg0 *kafka.ListClientVpcConnectionsInput) (*kafka.ListClientVpcConnectionsOutput, error)
ListClientVpcConnections mocks base method
func (*MockKafkaAPI) ListClientVpcConnectionsPages ¶ added in v1.44.252
func (m *MockKafkaAPI) ListClientVpcConnectionsPages(arg0 *kafka.ListClientVpcConnectionsInput, arg1 func(*kafka.ListClientVpcConnectionsOutput, bool) bool) error
ListClientVpcConnectionsPages mocks base method
func (*MockKafkaAPI) ListClientVpcConnectionsPagesWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) ListClientVpcConnectionsPagesWithContext(arg0 context.Context, arg1 *kafka.ListClientVpcConnectionsInput, arg2 func(*kafka.ListClientVpcConnectionsOutput, bool) bool, arg3 ...request.Option) error
ListClientVpcConnectionsPagesWithContext mocks base method
func (*MockKafkaAPI) ListClientVpcConnectionsRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) ListClientVpcConnectionsRequest(arg0 *kafka.ListClientVpcConnectionsInput) (*request.Request, *kafka.ListClientVpcConnectionsOutput)
ListClientVpcConnectionsRequest mocks base method
func (*MockKafkaAPI) ListClientVpcConnectionsWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) ListClientVpcConnectionsWithContext(arg0 context.Context, arg1 *kafka.ListClientVpcConnectionsInput, arg2 ...request.Option) (*kafka.ListClientVpcConnectionsOutput, error)
ListClientVpcConnectionsWithContext 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) ListClusterOperationsV2 ¶ added in v1.44.312
func (m *MockKafkaAPI) ListClusterOperationsV2(arg0 *kafka.ListClusterOperationsV2Input) (*kafka.ListClusterOperationsV2Output, error)
ListClusterOperationsV2 mocks base method
func (*MockKafkaAPI) ListClusterOperationsV2Pages ¶ added in v1.44.312
func (m *MockKafkaAPI) ListClusterOperationsV2Pages(arg0 *kafka.ListClusterOperationsV2Input, arg1 func(*kafka.ListClusterOperationsV2Output, bool) bool) error
ListClusterOperationsV2Pages mocks base method
func (*MockKafkaAPI) ListClusterOperationsV2PagesWithContext ¶ added in v1.44.312
func (m *MockKafkaAPI) ListClusterOperationsV2PagesWithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsV2Input, arg2 func(*kafka.ListClusterOperationsV2Output, bool) bool, arg3 ...request.Option) error
ListClusterOperationsV2PagesWithContext mocks base method
func (*MockKafkaAPI) ListClusterOperationsV2Request ¶ added in v1.44.312
func (m *MockKafkaAPI) ListClusterOperationsV2Request(arg0 *kafka.ListClusterOperationsV2Input) (*request.Request, *kafka.ListClusterOperationsV2Output)
ListClusterOperationsV2Request mocks base method
func (*MockKafkaAPI) ListClusterOperationsV2WithContext ¶ added in v1.44.312
func (m *MockKafkaAPI) ListClusterOperationsV2WithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsV2Input, arg2 ...request.Option) (*kafka.ListClusterOperationsV2Output, error)
ListClusterOperationsV2WithContext 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) ListClustersV2 ¶
func (m *MockKafkaAPI) ListClustersV2(arg0 *kafka.ListClustersV2Input) (*kafka.ListClustersV2Output, error)
ListClustersV2 mocks base method
func (*MockKafkaAPI) ListClustersV2Pages ¶
func (m *MockKafkaAPI) ListClustersV2Pages(arg0 *kafka.ListClustersV2Input, arg1 func(*kafka.ListClustersV2Output, bool) bool) error
ListClustersV2Pages mocks base method
func (*MockKafkaAPI) ListClustersV2PagesWithContext ¶
func (m *MockKafkaAPI) ListClustersV2PagesWithContext(arg0 context.Context, arg1 *kafka.ListClustersV2Input, arg2 func(*kafka.ListClustersV2Output, bool) bool, arg3 ...request.Option) error
ListClustersV2PagesWithContext mocks base method
func (*MockKafkaAPI) ListClustersV2Request ¶
func (m *MockKafkaAPI) ListClustersV2Request(arg0 *kafka.ListClustersV2Input) (*request.Request, *kafka.ListClustersV2Output)
ListClustersV2Request mocks base method
func (*MockKafkaAPI) ListClustersV2WithContext ¶
func (m *MockKafkaAPI) ListClustersV2WithContext(arg0 context.Context, arg1 *kafka.ListClustersV2Input, arg2 ...request.Option) (*kafka.ListClustersV2Output, error)
ListClustersV2WithContext 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) ListVpcConnections ¶ added in v1.44.252
func (m *MockKafkaAPI) ListVpcConnections(arg0 *kafka.ListVpcConnectionsInput) (*kafka.ListVpcConnectionsOutput, error)
ListVpcConnections mocks base method
func (*MockKafkaAPI) ListVpcConnectionsPages ¶ added in v1.44.252
func (m *MockKafkaAPI) ListVpcConnectionsPages(arg0 *kafka.ListVpcConnectionsInput, arg1 func(*kafka.ListVpcConnectionsOutput, bool) bool) error
ListVpcConnectionsPages mocks base method
func (*MockKafkaAPI) ListVpcConnectionsPagesWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) ListVpcConnectionsPagesWithContext(arg0 context.Context, arg1 *kafka.ListVpcConnectionsInput, arg2 func(*kafka.ListVpcConnectionsOutput, bool) bool, arg3 ...request.Option) error
ListVpcConnectionsPagesWithContext mocks base method
func (*MockKafkaAPI) ListVpcConnectionsRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) ListVpcConnectionsRequest(arg0 *kafka.ListVpcConnectionsInput) (*request.Request, *kafka.ListVpcConnectionsOutput)
ListVpcConnectionsRequest mocks base method
func (*MockKafkaAPI) ListVpcConnectionsWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) ListVpcConnectionsWithContext(arg0 context.Context, arg1 *kafka.ListVpcConnectionsInput, arg2 ...request.Option) (*kafka.ListVpcConnectionsOutput, error)
ListVpcConnectionsWithContext mocks base method
func (*MockKafkaAPI) PutClusterPolicy ¶ added in v1.44.252
func (m *MockKafkaAPI) PutClusterPolicy(arg0 *kafka.PutClusterPolicyInput) (*kafka.PutClusterPolicyOutput, error)
PutClusterPolicy mocks base method
func (*MockKafkaAPI) PutClusterPolicyRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) PutClusterPolicyRequest(arg0 *kafka.PutClusterPolicyInput) (*request.Request, *kafka.PutClusterPolicyOutput)
PutClusterPolicyRequest mocks base method
func (*MockKafkaAPI) PutClusterPolicyWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) PutClusterPolicyWithContext(arg0 context.Context, arg1 *kafka.PutClusterPolicyInput, arg2 ...request.Option) (*kafka.PutClusterPolicyOutput, error)
PutClusterPolicyWithContext 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) RejectClientVpcConnection ¶ added in v1.44.252
func (m *MockKafkaAPI) RejectClientVpcConnection(arg0 *kafka.RejectClientVpcConnectionInput) (*kafka.RejectClientVpcConnectionOutput, error)
RejectClientVpcConnection mocks base method
func (*MockKafkaAPI) RejectClientVpcConnectionRequest ¶ added in v1.44.252
func (m *MockKafkaAPI) RejectClientVpcConnectionRequest(arg0 *kafka.RejectClientVpcConnectionInput) (*request.Request, *kafka.RejectClientVpcConnectionOutput)
RejectClientVpcConnectionRequest mocks base method
func (*MockKafkaAPI) RejectClientVpcConnectionWithContext ¶ added in v1.44.252
func (m *MockKafkaAPI) RejectClientVpcConnectionWithContext(arg0 context.Context, arg1 *kafka.RejectClientVpcConnectionInput, arg2 ...request.Option) (*kafka.RejectClientVpcConnectionOutput, error)
RejectClientVpcConnectionWithContext 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) UpdateConnectivity ¶
func (m *MockKafkaAPI) UpdateConnectivity(arg0 *kafka.UpdateConnectivityInput) (*kafka.UpdateConnectivityOutput, error)
UpdateConnectivity mocks base method
func (*MockKafkaAPI) UpdateConnectivityRequest ¶
func (m *MockKafkaAPI) UpdateConnectivityRequest(arg0 *kafka.UpdateConnectivityInput) (*request.Request, *kafka.UpdateConnectivityOutput)
UpdateConnectivityRequest mocks base method
func (*MockKafkaAPI) UpdateConnectivityWithContext ¶
func (m *MockKafkaAPI) UpdateConnectivityWithContext(arg0 context.Context, arg1 *kafka.UpdateConnectivityInput, arg2 ...request.Option) (*kafka.UpdateConnectivityOutput, error)
UpdateConnectivityWithContext 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
func (*MockKafkaAPI) UpdateSecurity ¶
func (m *MockKafkaAPI) UpdateSecurity(arg0 *kafka.UpdateSecurityInput) (*kafka.UpdateSecurityOutput, error)
UpdateSecurity mocks base method
func (*MockKafkaAPI) UpdateSecurityRequest ¶
func (m *MockKafkaAPI) UpdateSecurityRequest(arg0 *kafka.UpdateSecurityInput) (*request.Request, *kafka.UpdateSecurityOutput)
UpdateSecurityRequest mocks base method
func (*MockKafkaAPI) UpdateSecurityWithContext ¶
func (m *MockKafkaAPI) UpdateSecurityWithContext(arg0 context.Context, arg1 *kafka.UpdateSecurityInput, arg2 ...request.Option) (*kafka.UpdateSecurityOutput, error)
UpdateSecurityWithContext mocks base method
func (*MockKafkaAPI) UpdateStorage ¶ added in v1.44.124
func (m *MockKafkaAPI) UpdateStorage(arg0 *kafka.UpdateStorageInput) (*kafka.UpdateStorageOutput, error)
UpdateStorage mocks base method
func (*MockKafkaAPI) UpdateStorageRequest ¶ added in v1.44.124
func (m *MockKafkaAPI) UpdateStorageRequest(arg0 *kafka.UpdateStorageInput) (*request.Request, *kafka.UpdateStorageOutput)
UpdateStorageRequest mocks base method
func (*MockKafkaAPI) UpdateStorageWithContext ¶ added in v1.44.124
func (m *MockKafkaAPI) UpdateStorageWithContext(arg0 context.Context, arg1 *kafka.UpdateStorageInput, arg2 ...request.Option) (*kafka.UpdateStorageOutput, error)
UpdateStorageWithContext 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) CreateClusterV2 ¶
func (mr *MockKafkaAPIMockRecorder) CreateClusterV2(arg0 interface{}) *gomock.Call
CreateClusterV2 indicates an expected call of CreateClusterV2
func (*MockKafkaAPIMockRecorder) CreateClusterV2Request ¶
func (mr *MockKafkaAPIMockRecorder) CreateClusterV2Request(arg0 interface{}) *gomock.Call
CreateClusterV2Request indicates an expected call of CreateClusterV2Request
func (*MockKafkaAPIMockRecorder) CreateClusterV2WithContext ¶
func (mr *MockKafkaAPIMockRecorder) CreateClusterV2WithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateClusterV2WithContext indicates an expected call of CreateClusterV2WithContext
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) CreateVpcConnection ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) CreateVpcConnection(arg0 interface{}) *gomock.Call
CreateVpcConnection indicates an expected call of CreateVpcConnection
func (*MockKafkaAPIMockRecorder) CreateVpcConnectionRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) CreateVpcConnectionRequest(arg0 interface{}) *gomock.Call
CreateVpcConnectionRequest indicates an expected call of CreateVpcConnectionRequest
func (*MockKafkaAPIMockRecorder) CreateVpcConnectionWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) CreateVpcConnectionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateVpcConnectionWithContext indicates an expected call of CreateVpcConnectionWithContext
func (*MockKafkaAPIMockRecorder) DeleteCluster ¶
func (mr *MockKafkaAPIMockRecorder) DeleteCluster(arg0 interface{}) *gomock.Call
DeleteCluster indicates an expected call of DeleteCluster
func (*MockKafkaAPIMockRecorder) DeleteClusterPolicy ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DeleteClusterPolicy(arg0 interface{}) *gomock.Call
DeleteClusterPolicy indicates an expected call of DeleteClusterPolicy
func (*MockKafkaAPIMockRecorder) DeleteClusterPolicyRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DeleteClusterPolicyRequest(arg0 interface{}) *gomock.Call
DeleteClusterPolicyRequest indicates an expected call of DeleteClusterPolicyRequest
func (*MockKafkaAPIMockRecorder) DeleteClusterPolicyWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DeleteClusterPolicyWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteClusterPolicyWithContext indicates an expected call of DeleteClusterPolicyWithContext
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) DeleteVpcConnection ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DeleteVpcConnection(arg0 interface{}) *gomock.Call
DeleteVpcConnection indicates an expected call of DeleteVpcConnection
func (*MockKafkaAPIMockRecorder) DeleteVpcConnectionRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DeleteVpcConnectionRequest(arg0 interface{}) *gomock.Call
DeleteVpcConnectionRequest indicates an expected call of DeleteVpcConnectionRequest
func (*MockKafkaAPIMockRecorder) DeleteVpcConnectionWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DeleteVpcConnectionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteVpcConnectionWithContext indicates an expected call of DeleteVpcConnectionWithContext
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) DescribeClusterOperationV2 ¶ added in v1.44.312
func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationV2(arg0 interface{}) *gomock.Call
DescribeClusterOperationV2 indicates an expected call of DescribeClusterOperationV2
func (*MockKafkaAPIMockRecorder) DescribeClusterOperationV2Request ¶ added in v1.44.312
func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationV2Request(arg0 interface{}) *gomock.Call
DescribeClusterOperationV2Request indicates an expected call of DescribeClusterOperationV2Request
func (*MockKafkaAPIMockRecorder) DescribeClusterOperationV2WithContext ¶ added in v1.44.312
func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationV2WithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeClusterOperationV2WithContext indicates an expected call of DescribeClusterOperationV2WithContext
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) DescribeClusterV2 ¶
func (mr *MockKafkaAPIMockRecorder) DescribeClusterV2(arg0 interface{}) *gomock.Call
DescribeClusterV2 indicates an expected call of DescribeClusterV2
func (*MockKafkaAPIMockRecorder) DescribeClusterV2Request ¶
func (mr *MockKafkaAPIMockRecorder) DescribeClusterV2Request(arg0 interface{}) *gomock.Call
DescribeClusterV2Request indicates an expected call of DescribeClusterV2Request
func (*MockKafkaAPIMockRecorder) DescribeClusterV2WithContext ¶
func (mr *MockKafkaAPIMockRecorder) DescribeClusterV2WithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeClusterV2WithContext indicates an expected call of DescribeClusterV2WithContext
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) DescribeVpcConnection ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DescribeVpcConnection(arg0 interface{}) *gomock.Call
DescribeVpcConnection indicates an expected call of DescribeVpcConnection
func (*MockKafkaAPIMockRecorder) DescribeVpcConnectionRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DescribeVpcConnectionRequest(arg0 interface{}) *gomock.Call
DescribeVpcConnectionRequest indicates an expected call of DescribeVpcConnectionRequest
func (*MockKafkaAPIMockRecorder) DescribeVpcConnectionWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) DescribeVpcConnectionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DescribeVpcConnectionWithContext indicates an expected call of DescribeVpcConnectionWithContext
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) GetClusterPolicy ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) GetClusterPolicy(arg0 interface{}) *gomock.Call
GetClusterPolicy indicates an expected call of GetClusterPolicy
func (*MockKafkaAPIMockRecorder) GetClusterPolicyRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) GetClusterPolicyRequest(arg0 interface{}) *gomock.Call
GetClusterPolicyRequest indicates an expected call of GetClusterPolicyRequest
func (*MockKafkaAPIMockRecorder) GetClusterPolicyWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) GetClusterPolicyWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetClusterPolicyWithContext indicates an expected call of GetClusterPolicyWithContext
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) ListClientVpcConnections ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnections(arg0 interface{}) *gomock.Call
ListClientVpcConnections indicates an expected call of ListClientVpcConnections
func (*MockKafkaAPIMockRecorder) ListClientVpcConnectionsPages ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnectionsPages(arg0, arg1 interface{}) *gomock.Call
ListClientVpcConnectionsPages indicates an expected call of ListClientVpcConnectionsPages
func (*MockKafkaAPIMockRecorder) ListClientVpcConnectionsPagesWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnectionsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListClientVpcConnectionsPagesWithContext indicates an expected call of ListClientVpcConnectionsPagesWithContext
func (*MockKafkaAPIMockRecorder) ListClientVpcConnectionsRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnectionsRequest(arg0 interface{}) *gomock.Call
ListClientVpcConnectionsRequest indicates an expected call of ListClientVpcConnectionsRequest
func (*MockKafkaAPIMockRecorder) ListClientVpcConnectionsWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListClientVpcConnectionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListClientVpcConnectionsWithContext indicates an expected call of ListClientVpcConnectionsWithContext
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) ListClusterOperationsV2 ¶ added in v1.44.312
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2(arg0 interface{}) *gomock.Call
ListClusterOperationsV2 indicates an expected call of ListClusterOperationsV2
func (*MockKafkaAPIMockRecorder) ListClusterOperationsV2Pages ¶ added in v1.44.312
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2Pages(arg0, arg1 interface{}) *gomock.Call
ListClusterOperationsV2Pages indicates an expected call of ListClusterOperationsV2Pages
func (*MockKafkaAPIMockRecorder) ListClusterOperationsV2PagesWithContext ¶ added in v1.44.312
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2PagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListClusterOperationsV2PagesWithContext indicates an expected call of ListClusterOperationsV2PagesWithContext
func (*MockKafkaAPIMockRecorder) ListClusterOperationsV2Request ¶ added in v1.44.312
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2Request(arg0 interface{}) *gomock.Call
ListClusterOperationsV2Request indicates an expected call of ListClusterOperationsV2Request
func (*MockKafkaAPIMockRecorder) ListClusterOperationsV2WithContext ¶ added in v1.44.312
func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsV2WithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListClusterOperationsV2WithContext indicates an expected call of ListClusterOperationsV2WithContext
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) ListClustersV2 ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersV2(arg0 interface{}) *gomock.Call
ListClustersV2 indicates an expected call of ListClustersV2
func (*MockKafkaAPIMockRecorder) ListClustersV2Pages ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersV2Pages(arg0, arg1 interface{}) *gomock.Call
ListClustersV2Pages indicates an expected call of ListClustersV2Pages
func (*MockKafkaAPIMockRecorder) ListClustersV2PagesWithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersV2PagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListClustersV2PagesWithContext indicates an expected call of ListClustersV2PagesWithContext
func (*MockKafkaAPIMockRecorder) ListClustersV2Request ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersV2Request(arg0 interface{}) *gomock.Call
ListClustersV2Request indicates an expected call of ListClustersV2Request
func (*MockKafkaAPIMockRecorder) ListClustersV2WithContext ¶
func (mr *MockKafkaAPIMockRecorder) ListClustersV2WithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListClustersV2WithContext indicates an expected call of ListClustersV2WithContext
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) ListVpcConnections ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListVpcConnections(arg0 interface{}) *gomock.Call
ListVpcConnections indicates an expected call of ListVpcConnections
func (*MockKafkaAPIMockRecorder) ListVpcConnectionsPages ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListVpcConnectionsPages(arg0, arg1 interface{}) *gomock.Call
ListVpcConnectionsPages indicates an expected call of ListVpcConnectionsPages
func (*MockKafkaAPIMockRecorder) ListVpcConnectionsPagesWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListVpcConnectionsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ListVpcConnectionsPagesWithContext indicates an expected call of ListVpcConnectionsPagesWithContext
func (*MockKafkaAPIMockRecorder) ListVpcConnectionsRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListVpcConnectionsRequest(arg0 interface{}) *gomock.Call
ListVpcConnectionsRequest indicates an expected call of ListVpcConnectionsRequest
func (*MockKafkaAPIMockRecorder) ListVpcConnectionsWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) ListVpcConnectionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ListVpcConnectionsWithContext indicates an expected call of ListVpcConnectionsWithContext
func (*MockKafkaAPIMockRecorder) PutClusterPolicy ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) PutClusterPolicy(arg0 interface{}) *gomock.Call
PutClusterPolicy indicates an expected call of PutClusterPolicy
func (*MockKafkaAPIMockRecorder) PutClusterPolicyRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) PutClusterPolicyRequest(arg0 interface{}) *gomock.Call
PutClusterPolicyRequest indicates an expected call of PutClusterPolicyRequest
func (*MockKafkaAPIMockRecorder) PutClusterPolicyWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) PutClusterPolicyWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PutClusterPolicyWithContext indicates an expected call of PutClusterPolicyWithContext
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) RejectClientVpcConnection ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) RejectClientVpcConnection(arg0 interface{}) *gomock.Call
RejectClientVpcConnection indicates an expected call of RejectClientVpcConnection
func (*MockKafkaAPIMockRecorder) RejectClientVpcConnectionRequest ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) RejectClientVpcConnectionRequest(arg0 interface{}) *gomock.Call
RejectClientVpcConnectionRequest indicates an expected call of RejectClientVpcConnectionRequest
func (*MockKafkaAPIMockRecorder) RejectClientVpcConnectionWithContext ¶ added in v1.44.252
func (mr *MockKafkaAPIMockRecorder) RejectClientVpcConnectionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
RejectClientVpcConnectionWithContext indicates an expected call of RejectClientVpcConnectionWithContext
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) UpdateConnectivity ¶
func (mr *MockKafkaAPIMockRecorder) UpdateConnectivity(arg0 interface{}) *gomock.Call
UpdateConnectivity indicates an expected call of UpdateConnectivity
func (*MockKafkaAPIMockRecorder) UpdateConnectivityRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateConnectivityRequest(arg0 interface{}) *gomock.Call
UpdateConnectivityRequest indicates an expected call of UpdateConnectivityRequest
func (*MockKafkaAPIMockRecorder) UpdateConnectivityWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateConnectivityWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateConnectivityWithContext indicates an expected call of UpdateConnectivityWithContext
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
func (*MockKafkaAPIMockRecorder) UpdateSecurity ¶
func (mr *MockKafkaAPIMockRecorder) UpdateSecurity(arg0 interface{}) *gomock.Call
UpdateSecurity indicates an expected call of UpdateSecurity
func (*MockKafkaAPIMockRecorder) UpdateSecurityRequest ¶
func (mr *MockKafkaAPIMockRecorder) UpdateSecurityRequest(arg0 interface{}) *gomock.Call
UpdateSecurityRequest indicates an expected call of UpdateSecurityRequest
func (*MockKafkaAPIMockRecorder) UpdateSecurityWithContext ¶
func (mr *MockKafkaAPIMockRecorder) UpdateSecurityWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateSecurityWithContext indicates an expected call of UpdateSecurityWithContext
func (*MockKafkaAPIMockRecorder) UpdateStorage ¶ added in v1.44.124
func (mr *MockKafkaAPIMockRecorder) UpdateStorage(arg0 interface{}) *gomock.Call
UpdateStorage indicates an expected call of UpdateStorage
func (*MockKafkaAPIMockRecorder) UpdateStorageRequest ¶ added in v1.44.124
func (mr *MockKafkaAPIMockRecorder) UpdateStorageRequest(arg0 interface{}) *gomock.Call
UpdateStorageRequest indicates an expected call of UpdateStorageRequest
func (*MockKafkaAPIMockRecorder) UpdateStorageWithContext ¶ added in v1.44.124
func (mr *MockKafkaAPIMockRecorder) UpdateStorageWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
UpdateStorageWithContext indicates an expected call of UpdateStorageWithContext