Documentation ¶
Index ¶
- type IClient
- func (_m *IClient) BatchAssociateScramSecret(ctx context.Context, params *kafka.BatchAssociateScramSecretInput, ...) (*kafka.BatchAssociateScramSecretOutput, error)
- func (_m *IClient) BatchDisassociateScramSecret(ctx context.Context, params *kafka.BatchDisassociateScramSecretInput, ...) (*kafka.BatchDisassociateScramSecretOutput, error)
- func (_m *IClient) CreateCluster(ctx context.Context, params *kafka.CreateClusterInput, ...) (*kafka.CreateClusterOutput, error)
- func (_m *IClient) CreateClusterV2(ctx context.Context, params *kafka.CreateClusterV2Input, ...) (*kafka.CreateClusterV2Output, error)
- func (_m *IClient) CreateConfiguration(ctx context.Context, params *kafka.CreateConfigurationInput, ...) (*kafka.CreateConfigurationOutput, error)
- func (_m *IClient) CreateReplicator(ctx context.Context, params *kafka.CreateReplicatorInput, ...) (*kafka.CreateReplicatorOutput, error)
- func (_m *IClient) CreateVpcConnection(ctx context.Context, params *kafka.CreateVpcConnectionInput, ...) (*kafka.CreateVpcConnectionOutput, error)
- func (_m *IClient) DeleteCluster(ctx context.Context, params *kafka.DeleteClusterInput, ...) (*kafka.DeleteClusterOutput, error)
- func (_m *IClient) DeleteClusterPolicy(ctx context.Context, params *kafka.DeleteClusterPolicyInput, ...) (*kafka.DeleteClusterPolicyOutput, error)
- func (_m *IClient) DeleteConfiguration(ctx context.Context, params *kafka.DeleteConfigurationInput, ...) (*kafka.DeleteConfigurationOutput, error)
- func (_m *IClient) DeleteReplicator(ctx context.Context, params *kafka.DeleteReplicatorInput, ...) (*kafka.DeleteReplicatorOutput, error)
- func (_m *IClient) DeleteVpcConnection(ctx context.Context, params *kafka.DeleteVpcConnectionInput, ...) (*kafka.DeleteVpcConnectionOutput, error)
- func (_m *IClient) DescribeCluster(ctx context.Context, params *kafka.DescribeClusterInput, ...) (*kafka.DescribeClusterOutput, error)
- func (_m *IClient) DescribeClusterOperation(ctx context.Context, params *kafka.DescribeClusterOperationInput, ...) (*kafka.DescribeClusterOperationOutput, error)
- func (_m *IClient) DescribeClusterOperationV2(ctx context.Context, params *kafka.DescribeClusterOperationV2Input, ...) (*kafka.DescribeClusterOperationV2Output, error)
- func (_m *IClient) DescribeClusterV2(ctx context.Context, params *kafka.DescribeClusterV2Input, ...) (*kafka.DescribeClusterV2Output, error)
- func (_m *IClient) DescribeConfiguration(ctx context.Context, params *kafka.DescribeConfigurationInput, ...) (*kafka.DescribeConfigurationOutput, error)
- func (_m *IClient) DescribeConfigurationRevision(ctx context.Context, params *kafka.DescribeConfigurationRevisionInput, ...) (*kafka.DescribeConfigurationRevisionOutput, error)
- func (_m *IClient) DescribeReplicator(ctx context.Context, params *kafka.DescribeReplicatorInput, ...) (*kafka.DescribeReplicatorOutput, error)
- func (_m *IClient) DescribeVpcConnection(ctx context.Context, params *kafka.DescribeVpcConnectionInput, ...) (*kafka.DescribeVpcConnectionOutput, error)
- func (_m *IClient) GetBootstrapBrokers(ctx context.Context, params *kafka.GetBootstrapBrokersInput, ...) (*kafka.GetBootstrapBrokersOutput, error)
- func (_m *IClient) GetClusterPolicy(ctx context.Context, params *kafka.GetClusterPolicyInput, ...) (*kafka.GetClusterPolicyOutput, error)
- func (_m *IClient) GetCompatibleKafkaVersions(ctx context.Context, params *kafka.GetCompatibleKafkaVersionsInput, ...) (*kafka.GetCompatibleKafkaVersionsOutput, error)
- func (_m *IClient) ListClientVpcConnections(ctx context.Context, params *kafka.ListClientVpcConnectionsInput, ...) (*kafka.ListClientVpcConnectionsOutput, error)
- func (_m *IClient) ListClusterOperations(ctx context.Context, params *kafka.ListClusterOperationsInput, ...) (*kafka.ListClusterOperationsOutput, error)
- func (_m *IClient) ListClusterOperationsV2(ctx context.Context, params *kafka.ListClusterOperationsV2Input, ...) (*kafka.ListClusterOperationsV2Output, error)
- func (_m *IClient) ListClusters(ctx context.Context, params *kafka.ListClustersInput, ...) (*kafka.ListClustersOutput, error)
- func (_m *IClient) ListClustersV2(ctx context.Context, params *kafka.ListClustersV2Input, ...) (*kafka.ListClustersV2Output, error)
- func (_m *IClient) ListConfigurationRevisions(ctx context.Context, params *kafka.ListConfigurationRevisionsInput, ...) (*kafka.ListConfigurationRevisionsOutput, error)
- func (_m *IClient) ListConfigurations(ctx context.Context, params *kafka.ListConfigurationsInput, ...) (*kafka.ListConfigurationsOutput, error)
- func (_m *IClient) ListKafkaVersions(ctx context.Context, params *kafka.ListKafkaVersionsInput, ...) (*kafka.ListKafkaVersionsOutput, error)
- func (_m *IClient) ListNodes(ctx context.Context, params *kafka.ListNodesInput, ...) (*kafka.ListNodesOutput, error)
- func (_m *IClient) ListReplicators(ctx context.Context, params *kafka.ListReplicatorsInput, ...) (*kafka.ListReplicatorsOutput, error)
- func (_m *IClient) ListScramSecrets(ctx context.Context, params *kafka.ListScramSecretsInput, ...) (*kafka.ListScramSecretsOutput, error)
- func (_m *IClient) ListTagsForResource(ctx context.Context, params *kafka.ListTagsForResourceInput, ...) (*kafka.ListTagsForResourceOutput, error)
- func (_m *IClient) ListVpcConnections(ctx context.Context, params *kafka.ListVpcConnectionsInput, ...) (*kafka.ListVpcConnectionsOutput, error)
- func (_m *IClient) Options() kafka.Options
- func (_m *IClient) PutClusterPolicy(ctx context.Context, params *kafka.PutClusterPolicyInput, ...) (*kafka.PutClusterPolicyOutput, error)
- func (_m *IClient) RebootBroker(ctx context.Context, params *kafka.RebootBrokerInput, ...) (*kafka.RebootBrokerOutput, error)
- func (_m *IClient) RejectClientVpcConnection(ctx context.Context, params *kafka.RejectClientVpcConnectionInput, ...) (*kafka.RejectClientVpcConnectionOutput, error)
- func (_m *IClient) TagResource(ctx context.Context, params *kafka.TagResourceInput, ...) (*kafka.TagResourceOutput, error)
- func (_m *IClient) UntagResource(ctx context.Context, params *kafka.UntagResourceInput, ...) (*kafka.UntagResourceOutput, error)
- func (_m *IClient) UpdateBrokerCount(ctx context.Context, params *kafka.UpdateBrokerCountInput, ...) (*kafka.UpdateBrokerCountOutput, error)
- func (_m *IClient) UpdateBrokerStorage(ctx context.Context, params *kafka.UpdateBrokerStorageInput, ...) (*kafka.UpdateBrokerStorageOutput, error)
- func (_m *IClient) UpdateBrokerType(ctx context.Context, params *kafka.UpdateBrokerTypeInput, ...) (*kafka.UpdateBrokerTypeOutput, error)
- func (_m *IClient) UpdateClusterConfiguration(ctx context.Context, params *kafka.UpdateClusterConfigurationInput, ...) (*kafka.UpdateClusterConfigurationOutput, error)
- func (_m *IClient) UpdateClusterKafkaVersion(ctx context.Context, params *kafka.UpdateClusterKafkaVersionInput, ...) (*kafka.UpdateClusterKafkaVersionOutput, error)
- func (_m *IClient) UpdateConfiguration(ctx context.Context, params *kafka.UpdateConfigurationInput, ...) (*kafka.UpdateConfigurationOutput, error)
- func (_m *IClient) UpdateConnectivity(ctx context.Context, params *kafka.UpdateConnectivityInput, ...) (*kafka.UpdateConnectivityOutput, error)
- func (_m *IClient) UpdateMonitoring(ctx context.Context, params *kafka.UpdateMonitoringInput, ...) (*kafka.UpdateMonitoringOutput, error)
- func (_m *IClient) UpdateReplicationInfo(ctx context.Context, params *kafka.UpdateReplicationInfoInput, ...) (*kafka.UpdateReplicationInfoOutput, error)
- func (_m *IClient) UpdateSecurity(ctx context.Context, params *kafka.UpdateSecurityInput, ...) (*kafka.UpdateSecurityOutput, error)
- func (_m *IClient) UpdateStorage(ctx context.Context, params *kafka.UpdateStorageInput, ...) (*kafka.UpdateStorageOutput, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IClient ¶
IClient is an autogenerated mock type for the IClient type
func NewIClient ¶
NewIClient creates a new instance of IClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*IClient) BatchAssociateScramSecret ¶
func (_m *IClient) BatchAssociateScramSecret(ctx context.Context, params *kafka.BatchAssociateScramSecretInput, optFns ...func(*kafka.Options)) (*kafka.BatchAssociateScramSecretOutput, error)
BatchAssociateScramSecret provides a mock function with given fields: ctx, params, optFns
func (*IClient) BatchDisassociateScramSecret ¶
func (_m *IClient) BatchDisassociateScramSecret(ctx context.Context, params *kafka.BatchDisassociateScramSecretInput, optFns ...func(*kafka.Options)) (*kafka.BatchDisassociateScramSecretOutput, error)
BatchDisassociateScramSecret provides a mock function with given fields: ctx, params, optFns
func (*IClient) CreateCluster ¶
func (_m *IClient) CreateCluster(ctx context.Context, params *kafka.CreateClusterInput, optFns ...func(*kafka.Options)) (*kafka.CreateClusterOutput, error)
CreateCluster provides a mock function with given fields: ctx, params, optFns
func (*IClient) CreateClusterV2 ¶
func (_m *IClient) CreateClusterV2(ctx context.Context, params *kafka.CreateClusterV2Input, optFns ...func(*kafka.Options)) (*kafka.CreateClusterV2Output, error)
CreateClusterV2 provides a mock function with given fields: ctx, params, optFns
func (*IClient) CreateConfiguration ¶
func (_m *IClient) CreateConfiguration(ctx context.Context, params *kafka.CreateConfigurationInput, optFns ...func(*kafka.Options)) (*kafka.CreateConfigurationOutput, error)
CreateConfiguration provides a mock function with given fields: ctx, params, optFns
func (*IClient) CreateReplicator ¶
func (_m *IClient) CreateReplicator(ctx context.Context, params *kafka.CreateReplicatorInput, optFns ...func(*kafka.Options)) (*kafka.CreateReplicatorOutput, error)
CreateReplicator provides a mock function with given fields: ctx, params, optFns
func (*IClient) CreateVpcConnection ¶
func (_m *IClient) CreateVpcConnection(ctx context.Context, params *kafka.CreateVpcConnectionInput, optFns ...func(*kafka.Options)) (*kafka.CreateVpcConnectionOutput, error)
CreateVpcConnection provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeleteCluster ¶
func (_m *IClient) DeleteCluster(ctx context.Context, params *kafka.DeleteClusterInput, optFns ...func(*kafka.Options)) (*kafka.DeleteClusterOutput, error)
DeleteCluster provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeleteClusterPolicy ¶
func (_m *IClient) DeleteClusterPolicy(ctx context.Context, params *kafka.DeleteClusterPolicyInput, optFns ...func(*kafka.Options)) (*kafka.DeleteClusterPolicyOutput, error)
DeleteClusterPolicy provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeleteConfiguration ¶
func (_m *IClient) DeleteConfiguration(ctx context.Context, params *kafka.DeleteConfigurationInput, optFns ...func(*kafka.Options)) (*kafka.DeleteConfigurationOutput, error)
DeleteConfiguration provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeleteReplicator ¶
func (_m *IClient) DeleteReplicator(ctx context.Context, params *kafka.DeleteReplicatorInput, optFns ...func(*kafka.Options)) (*kafka.DeleteReplicatorOutput, error)
DeleteReplicator provides a mock function with given fields: ctx, params, optFns
func (*IClient) DeleteVpcConnection ¶
func (_m *IClient) DeleteVpcConnection(ctx context.Context, params *kafka.DeleteVpcConnectionInput, optFns ...func(*kafka.Options)) (*kafka.DeleteVpcConnectionOutput, error)
DeleteVpcConnection provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeCluster ¶
func (_m *IClient) DescribeCluster(ctx context.Context, params *kafka.DescribeClusterInput, optFns ...func(*kafka.Options)) (*kafka.DescribeClusterOutput, error)
DescribeCluster provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeClusterOperation ¶
func (_m *IClient) DescribeClusterOperation(ctx context.Context, params *kafka.DescribeClusterOperationInput, optFns ...func(*kafka.Options)) (*kafka.DescribeClusterOperationOutput, error)
DescribeClusterOperation provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeClusterOperationV2 ¶
func (_m *IClient) DescribeClusterOperationV2(ctx context.Context, params *kafka.DescribeClusterOperationV2Input, optFns ...func(*kafka.Options)) (*kafka.DescribeClusterOperationV2Output, error)
DescribeClusterOperationV2 provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeClusterV2 ¶
func (_m *IClient) DescribeClusterV2(ctx context.Context, params *kafka.DescribeClusterV2Input, optFns ...func(*kafka.Options)) (*kafka.DescribeClusterV2Output, error)
DescribeClusterV2 provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeConfiguration ¶
func (_m *IClient) DescribeConfiguration(ctx context.Context, params *kafka.DescribeConfigurationInput, optFns ...func(*kafka.Options)) (*kafka.DescribeConfigurationOutput, error)
DescribeConfiguration provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeConfigurationRevision ¶
func (_m *IClient) DescribeConfigurationRevision(ctx context.Context, params *kafka.DescribeConfigurationRevisionInput, optFns ...func(*kafka.Options)) (*kafka.DescribeConfigurationRevisionOutput, error)
DescribeConfigurationRevision provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeReplicator ¶
func (_m *IClient) DescribeReplicator(ctx context.Context, params *kafka.DescribeReplicatorInput, optFns ...func(*kafka.Options)) (*kafka.DescribeReplicatorOutput, error)
DescribeReplicator provides a mock function with given fields: ctx, params, optFns
func (*IClient) DescribeVpcConnection ¶
func (_m *IClient) DescribeVpcConnection(ctx context.Context, params *kafka.DescribeVpcConnectionInput, optFns ...func(*kafka.Options)) (*kafka.DescribeVpcConnectionOutput, error)
DescribeVpcConnection provides a mock function with given fields: ctx, params, optFns
func (*IClient) GetBootstrapBrokers ¶
func (_m *IClient) GetBootstrapBrokers(ctx context.Context, params *kafka.GetBootstrapBrokersInput, optFns ...func(*kafka.Options)) (*kafka.GetBootstrapBrokersOutput, error)
GetBootstrapBrokers provides a mock function with given fields: ctx, params, optFns
func (*IClient) GetClusterPolicy ¶
func (_m *IClient) GetClusterPolicy(ctx context.Context, params *kafka.GetClusterPolicyInput, optFns ...func(*kafka.Options)) (*kafka.GetClusterPolicyOutput, error)
GetClusterPolicy provides a mock function with given fields: ctx, params, optFns
func (*IClient) GetCompatibleKafkaVersions ¶
func (_m *IClient) GetCompatibleKafkaVersions(ctx context.Context, params *kafka.GetCompatibleKafkaVersionsInput, optFns ...func(*kafka.Options)) (*kafka.GetCompatibleKafkaVersionsOutput, error)
GetCompatibleKafkaVersions provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListClientVpcConnections ¶
func (_m *IClient) ListClientVpcConnections(ctx context.Context, params *kafka.ListClientVpcConnectionsInput, optFns ...func(*kafka.Options)) (*kafka.ListClientVpcConnectionsOutput, error)
ListClientVpcConnections provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListClusterOperations ¶
func (_m *IClient) ListClusterOperations(ctx context.Context, params *kafka.ListClusterOperationsInput, optFns ...func(*kafka.Options)) (*kafka.ListClusterOperationsOutput, error)
ListClusterOperations provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListClusterOperationsV2 ¶
func (_m *IClient) ListClusterOperationsV2(ctx context.Context, params *kafka.ListClusterOperationsV2Input, optFns ...func(*kafka.Options)) (*kafka.ListClusterOperationsV2Output, error)
ListClusterOperationsV2 provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListClusters ¶
func (_m *IClient) ListClusters(ctx context.Context, params *kafka.ListClustersInput, optFns ...func(*kafka.Options)) (*kafka.ListClustersOutput, error)
ListClusters provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListClustersV2 ¶
func (_m *IClient) ListClustersV2(ctx context.Context, params *kafka.ListClustersV2Input, optFns ...func(*kafka.Options)) (*kafka.ListClustersV2Output, error)
ListClustersV2 provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListConfigurationRevisions ¶
func (_m *IClient) ListConfigurationRevisions(ctx context.Context, params *kafka.ListConfigurationRevisionsInput, optFns ...func(*kafka.Options)) (*kafka.ListConfigurationRevisionsOutput, error)
ListConfigurationRevisions provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListConfigurations ¶
func (_m *IClient) ListConfigurations(ctx context.Context, params *kafka.ListConfigurationsInput, optFns ...func(*kafka.Options)) (*kafka.ListConfigurationsOutput, error)
ListConfigurations provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListKafkaVersions ¶
func (_m *IClient) ListKafkaVersions(ctx context.Context, params *kafka.ListKafkaVersionsInput, optFns ...func(*kafka.Options)) (*kafka.ListKafkaVersionsOutput, error)
ListKafkaVersions provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListNodes ¶
func (_m *IClient) ListNodes(ctx context.Context, params *kafka.ListNodesInput, optFns ...func(*kafka.Options)) (*kafka.ListNodesOutput, error)
ListNodes provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListReplicators ¶
func (_m *IClient) ListReplicators(ctx context.Context, params *kafka.ListReplicatorsInput, optFns ...func(*kafka.Options)) (*kafka.ListReplicatorsOutput, error)
ListReplicators provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListScramSecrets ¶
func (_m *IClient) ListScramSecrets(ctx context.Context, params *kafka.ListScramSecretsInput, optFns ...func(*kafka.Options)) (*kafka.ListScramSecretsOutput, error)
ListScramSecrets provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListTagsForResource ¶
func (_m *IClient) ListTagsForResource(ctx context.Context, params *kafka.ListTagsForResourceInput, optFns ...func(*kafka.Options)) (*kafka.ListTagsForResourceOutput, error)
ListTagsForResource provides a mock function with given fields: ctx, params, optFns
func (*IClient) ListVpcConnections ¶
func (_m *IClient) ListVpcConnections(ctx context.Context, params *kafka.ListVpcConnectionsInput, optFns ...func(*kafka.Options)) (*kafka.ListVpcConnectionsOutput, error)
ListVpcConnections provides a mock function with given fields: ctx, params, optFns
func (*IClient) PutClusterPolicy ¶
func (_m *IClient) PutClusterPolicy(ctx context.Context, params *kafka.PutClusterPolicyInput, optFns ...func(*kafka.Options)) (*kafka.PutClusterPolicyOutput, error)
PutClusterPolicy provides a mock function with given fields: ctx, params, optFns
func (*IClient) RebootBroker ¶
func (_m *IClient) RebootBroker(ctx context.Context, params *kafka.RebootBrokerInput, optFns ...func(*kafka.Options)) (*kafka.RebootBrokerOutput, error)
RebootBroker provides a mock function with given fields: ctx, params, optFns
func (*IClient) RejectClientVpcConnection ¶
func (_m *IClient) RejectClientVpcConnection(ctx context.Context, params *kafka.RejectClientVpcConnectionInput, optFns ...func(*kafka.Options)) (*kafka.RejectClientVpcConnectionOutput, error)
RejectClientVpcConnection provides a mock function with given fields: ctx, params, optFns
func (*IClient) TagResource ¶
func (_m *IClient) TagResource(ctx context.Context, params *kafka.TagResourceInput, optFns ...func(*kafka.Options)) (*kafka.TagResourceOutput, error)
TagResource provides a mock function with given fields: ctx, params, optFns
func (*IClient) UntagResource ¶
func (_m *IClient) UntagResource(ctx context.Context, params *kafka.UntagResourceInput, optFns ...func(*kafka.Options)) (*kafka.UntagResourceOutput, error)
UntagResource provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateBrokerCount ¶
func (_m *IClient) UpdateBrokerCount(ctx context.Context, params *kafka.UpdateBrokerCountInput, optFns ...func(*kafka.Options)) (*kafka.UpdateBrokerCountOutput, error)
UpdateBrokerCount provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateBrokerStorage ¶
func (_m *IClient) UpdateBrokerStorage(ctx context.Context, params *kafka.UpdateBrokerStorageInput, optFns ...func(*kafka.Options)) (*kafka.UpdateBrokerStorageOutput, error)
UpdateBrokerStorage provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateBrokerType ¶
func (_m *IClient) UpdateBrokerType(ctx context.Context, params *kafka.UpdateBrokerTypeInput, optFns ...func(*kafka.Options)) (*kafka.UpdateBrokerTypeOutput, error)
UpdateBrokerType provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateClusterConfiguration ¶
func (_m *IClient) UpdateClusterConfiguration(ctx context.Context, params *kafka.UpdateClusterConfigurationInput, optFns ...func(*kafka.Options)) (*kafka.UpdateClusterConfigurationOutput, error)
UpdateClusterConfiguration provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateClusterKafkaVersion ¶
func (_m *IClient) UpdateClusterKafkaVersion(ctx context.Context, params *kafka.UpdateClusterKafkaVersionInput, optFns ...func(*kafka.Options)) (*kafka.UpdateClusterKafkaVersionOutput, error)
UpdateClusterKafkaVersion provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateConfiguration ¶
func (_m *IClient) UpdateConfiguration(ctx context.Context, params *kafka.UpdateConfigurationInput, optFns ...func(*kafka.Options)) (*kafka.UpdateConfigurationOutput, error)
UpdateConfiguration provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateConnectivity ¶
func (_m *IClient) UpdateConnectivity(ctx context.Context, params *kafka.UpdateConnectivityInput, optFns ...func(*kafka.Options)) (*kafka.UpdateConnectivityOutput, error)
UpdateConnectivity provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateMonitoring ¶
func (_m *IClient) UpdateMonitoring(ctx context.Context, params *kafka.UpdateMonitoringInput, optFns ...func(*kafka.Options)) (*kafka.UpdateMonitoringOutput, error)
UpdateMonitoring provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateReplicationInfo ¶
func (_m *IClient) UpdateReplicationInfo(ctx context.Context, params *kafka.UpdateReplicationInfoInput, optFns ...func(*kafka.Options)) (*kafka.UpdateReplicationInfoOutput, error)
UpdateReplicationInfo provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateSecurity ¶
func (_m *IClient) UpdateSecurity(ctx context.Context, params *kafka.UpdateSecurityInput, optFns ...func(*kafka.Options)) (*kafka.UpdateSecurityOutput, error)
UpdateSecurity provides a mock function with given fields: ctx, params, optFns
func (*IClient) UpdateStorage ¶
func (_m *IClient) UpdateStorage(ctx context.Context, params *kafka.UpdateStorageInput, optFns ...func(*kafka.Options)) (*kafka.UpdateStorageOutput, error)
UpdateStorage provides a mock function with given fields: ctx, params, optFns