kafkamock

package
v1.43.19 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 31, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package kafkamock is a generated GoMock package.

Index

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) DeleteCluster 

func (m *MockKafkaAPI) DeleteCluster(arg0 *kafka.DeleteClusterInput) (*kafka.DeleteClusterOutput, error)

DeleteCluster mocks base method

func (*MockKafkaAPI) DeleteClusterRequest 

func (m *MockKafkaAPI) DeleteClusterRequest(arg0 *kafka.DeleteClusterInput) (*request.Request, *kafka.DeleteClusterOutput)

DeleteClusterRequest mocks base method

func (*MockKafkaAPI) DeleteClusterWithContext 

func (m *MockKafkaAPI) DeleteClusterWithContext(arg0 context.Context, arg1 *kafka.DeleteClusterInput, arg2 ...request.Option) (*kafka.DeleteClusterOutput, error)

DeleteClusterWithContext mocks base method

func (*MockKafkaAPI) DeleteConfiguration 

func (m *MockKafkaAPI) DeleteConfiguration(arg0 *kafka.DeleteConfigurationInput) (*kafka.DeleteConfigurationOutput, error)

DeleteConfiguration mocks base method

func (*MockKafkaAPI) DeleteConfigurationRequest 

func (m *MockKafkaAPI) DeleteConfigurationRequest(arg0 *kafka.DeleteConfigurationInput) (*request.Request, *kafka.DeleteConfigurationOutput)

DeleteConfigurationRequest mocks base method

func (*MockKafkaAPI) DeleteConfigurationWithContext 

func (m *MockKafkaAPI) DeleteConfigurationWithContext(arg0 context.Context, arg1 *kafka.DeleteConfigurationInput, arg2 ...request.Option) (*kafka.DeleteConfigurationOutput, error)

DeleteConfigurationWithContext mocks base method

func (*MockKafkaAPI) DescribeCluster 

func (m *MockKafkaAPI) DescribeCluster(arg0 *kafka.DescribeClusterInput) (*kafka.DescribeClusterOutput, error)

DescribeCluster mocks base method

func (*MockKafkaAPI) DescribeClusterOperation 

func (m *MockKafkaAPI) DescribeClusterOperation(arg0 *kafka.DescribeClusterOperationInput) (*kafka.DescribeClusterOperationOutput, error)

DescribeClusterOperation mocks base method

func (*MockKafkaAPI) DescribeClusterOperationRequest 

func (m *MockKafkaAPI) DescribeClusterOperationRequest(arg0 *kafka.DescribeClusterOperationInput) (*request.Request, *kafka.DescribeClusterOperationOutput)

DescribeClusterOperationRequest mocks base method

func (*MockKafkaAPI) DescribeClusterOperationWithContext 

func (m *MockKafkaAPI) DescribeClusterOperationWithContext(arg0 context.Context, arg1 *kafka.DescribeClusterOperationInput, arg2 ...request.Option) (*kafka.DescribeClusterOperationOutput, error)

DescribeClusterOperationWithContext mocks base method

func (*MockKafkaAPI) DescribeClusterRequest 

func (m *MockKafkaAPI) DescribeClusterRequest(arg0 *kafka.DescribeClusterInput) (*request.Request, *kafka.DescribeClusterOutput)

DescribeClusterRequest mocks base method

func (*MockKafkaAPI) 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) EXPECT 

func (m *MockKafkaAPI) EXPECT() *MockKafkaAPIMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockKafkaAPI) GetBootstrapBrokers 

func (m *MockKafkaAPI) GetBootstrapBrokers(arg0 *kafka.GetBootstrapBrokersInput) (*kafka.GetBootstrapBrokersOutput, error)

GetBootstrapBrokers mocks base method

func (*MockKafkaAPI) GetBootstrapBrokersRequest 

func (m *MockKafkaAPI) GetBootstrapBrokersRequest(arg0 *kafka.GetBootstrapBrokersInput) (*request.Request, *kafka.GetBootstrapBrokersOutput)

GetBootstrapBrokersRequest mocks base method

func (*MockKafkaAPI) GetBootstrapBrokersWithContext 

func (m *MockKafkaAPI) GetBootstrapBrokersWithContext(arg0 context.Context, arg1 *kafka.GetBootstrapBrokersInput, arg2 ...request.Option) (*kafka.GetBootstrapBrokersOutput, error)

GetBootstrapBrokersWithContext mocks base method

func (*MockKafkaAPI) GetCompatibleKafkaVersions 

func (m *MockKafkaAPI) GetCompatibleKafkaVersions(arg0 *kafka.GetCompatibleKafkaVersionsInput) (*kafka.GetCompatibleKafkaVersionsOutput, error)

GetCompatibleKafkaVersions mocks base method

func (*MockKafkaAPI) GetCompatibleKafkaVersionsRequest 

func (m *MockKafkaAPI) GetCompatibleKafkaVersionsRequest(arg0 *kafka.GetCompatibleKafkaVersionsInput) (*request.Request, *kafka.GetCompatibleKafkaVersionsOutput)

GetCompatibleKafkaVersionsRequest mocks base method

func (*MockKafkaAPI) GetCompatibleKafkaVersionsWithContext 

func (m *MockKafkaAPI) GetCompatibleKafkaVersionsWithContext(arg0 context.Context, arg1 *kafka.GetCompatibleKafkaVersionsInput, arg2 ...request.Option) (*kafka.GetCompatibleKafkaVersionsOutput, error)

GetCompatibleKafkaVersionsWithContext mocks base method

func (*MockKafkaAPI) ListClusterOperations 

func (m *MockKafkaAPI) ListClusterOperations(arg0 *kafka.ListClusterOperationsInput) (*kafka.ListClusterOperationsOutput, error)

ListClusterOperations mocks base method

func (*MockKafkaAPI) ListClusterOperationsPages 

func (m *MockKafkaAPI) ListClusterOperationsPages(arg0 *kafka.ListClusterOperationsInput, arg1 func(*kafka.ListClusterOperationsOutput, bool) bool) error

ListClusterOperationsPages mocks base method

func (*MockKafkaAPI) ListClusterOperationsPagesWithContext 

func (m *MockKafkaAPI) ListClusterOperationsPagesWithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsInput, arg2 func(*kafka.ListClusterOperationsOutput, bool) bool, arg3 ...request.Option) error

ListClusterOperationsPagesWithContext mocks base method

func (*MockKafkaAPI) ListClusterOperationsRequest 

func (m *MockKafkaAPI) ListClusterOperationsRequest(arg0 *kafka.ListClusterOperationsInput) (*request.Request, *kafka.ListClusterOperationsOutput)

ListClusterOperationsRequest mocks base method

func (*MockKafkaAPI) ListClusterOperationsWithContext 

func (m *MockKafkaAPI) ListClusterOperationsWithContext(arg0 context.Context, arg1 *kafka.ListClusterOperationsInput, arg2 ...request.Option) (*kafka.ListClusterOperationsOutput, error)

ListClusterOperationsWithContext mocks base method

func (*MockKafkaAPI) ListClusters 

func (m *MockKafkaAPI) ListClusters(arg0 *kafka.ListClustersInput) (*kafka.ListClustersOutput, error)

ListClusters mocks base method

func (*MockKafkaAPI) ListClustersPages 

func (m *MockKafkaAPI) ListClustersPages(arg0 *kafka.ListClustersInput, arg1 func(*kafka.ListClustersOutput, bool) bool) error

ListClustersPages mocks base method

func (*MockKafkaAPI) ListClustersPagesWithContext 

func (m *MockKafkaAPI) ListClustersPagesWithContext(arg0 context.Context, arg1 *kafka.ListClustersInput, arg2 func(*kafka.ListClustersOutput, bool) bool, arg3 ...request.Option) error

ListClustersPagesWithContext mocks base method

func (*MockKafkaAPI) ListClustersRequest 

func (m *MockKafkaAPI) ListClustersRequest(arg0 *kafka.ListClustersInput) (*request.Request, *kafka.ListClustersOutput)

ListClustersRequest mocks base method

func (*MockKafkaAPI) 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) RebootBroker 

func (m *MockKafkaAPI) RebootBroker(arg0 *kafka.RebootBrokerInput) (*kafka.RebootBrokerOutput, error)

RebootBroker mocks base method

func (*MockKafkaAPI) RebootBrokerRequest 

func (m *MockKafkaAPI) RebootBrokerRequest(arg0 *kafka.RebootBrokerInput) (*request.Request, *kafka.RebootBrokerOutput)

RebootBrokerRequest mocks base method

func (*MockKafkaAPI) RebootBrokerWithContext 

func (m *MockKafkaAPI) RebootBrokerWithContext(arg0 context.Context, arg1 *kafka.RebootBrokerInput, arg2 ...request.Option) (*kafka.RebootBrokerOutput, error)

RebootBrokerWithContext mocks base method

func (*MockKafkaAPI) TagResource 

func (m *MockKafkaAPI) TagResource(arg0 *kafka.TagResourceInput) (*kafka.TagResourceOutput, error)

TagResource mocks base method

func (*MockKafkaAPI) TagResourceRequest 

func (m *MockKafkaAPI) TagResourceRequest(arg0 *kafka.TagResourceInput) (*request.Request, *kafka.TagResourceOutput)

TagResourceRequest mocks base method

func (*MockKafkaAPI) TagResourceWithContext 

func (m *MockKafkaAPI) TagResourceWithContext(arg0 context.Context, arg1 *kafka.TagResourceInput, arg2 ...request.Option) (*kafka.TagResourceOutput, error)

TagResourceWithContext mocks base method

func (*MockKafkaAPI) UntagResource 

func (m *MockKafkaAPI) UntagResource(arg0 *kafka.UntagResourceInput) (*kafka.UntagResourceOutput, error)

UntagResource mocks base method

func (*MockKafkaAPI) UntagResourceRequest 

func (m *MockKafkaAPI) UntagResourceRequest(arg0 *kafka.UntagResourceInput) (*request.Request, *kafka.UntagResourceOutput)

UntagResourceRequest mocks base method

func (*MockKafkaAPI) UntagResourceWithContext 

func (m *MockKafkaAPI) UntagResourceWithContext(arg0 context.Context, arg1 *kafka.UntagResourceInput, arg2 ...request.Option) (*kafka.UntagResourceOutput, error)

UntagResourceWithContext mocks base method

func (*MockKafkaAPI) UpdateBrokerCount 

func (m *MockKafkaAPI) UpdateBrokerCount(arg0 *kafka.UpdateBrokerCountInput) (*kafka.UpdateBrokerCountOutput, error)

UpdateBrokerCount mocks base method

func (*MockKafkaAPI) UpdateBrokerCountRequest 

func (m *MockKafkaAPI) UpdateBrokerCountRequest(arg0 *kafka.UpdateBrokerCountInput) (*request.Request, *kafka.UpdateBrokerCountOutput)

UpdateBrokerCountRequest mocks base method

func (*MockKafkaAPI) UpdateBrokerCountWithContext 

func (m *MockKafkaAPI) UpdateBrokerCountWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerCountInput, arg2 ...request.Option) (*kafka.UpdateBrokerCountOutput, error)

UpdateBrokerCountWithContext mocks base method

func (*MockKafkaAPI) UpdateBrokerStorage 

func (m *MockKafkaAPI) UpdateBrokerStorage(arg0 *kafka.UpdateBrokerStorageInput) (*kafka.UpdateBrokerStorageOutput, error)

UpdateBrokerStorage mocks base method

func (*MockKafkaAPI) UpdateBrokerStorageRequest 

func (m *MockKafkaAPI) UpdateBrokerStorageRequest(arg0 *kafka.UpdateBrokerStorageInput) (*request.Request, *kafka.UpdateBrokerStorageOutput)

UpdateBrokerStorageRequest mocks base method

func (*MockKafkaAPI) UpdateBrokerStorageWithContext 

func (m *MockKafkaAPI) UpdateBrokerStorageWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerStorageInput, arg2 ...request.Option) (*kafka.UpdateBrokerStorageOutput, error)

UpdateBrokerStorageWithContext mocks base method

func (*MockKafkaAPI) UpdateBrokerType 

func (m *MockKafkaAPI) UpdateBrokerType(arg0 *kafka.UpdateBrokerTypeInput) (*kafka.UpdateBrokerTypeOutput, error)

UpdateBrokerType mocks base method

func (*MockKafkaAPI) UpdateBrokerTypeRequest 

func (m *MockKafkaAPI) UpdateBrokerTypeRequest(arg0 *kafka.UpdateBrokerTypeInput) (*request.Request, *kafka.UpdateBrokerTypeOutput)

UpdateBrokerTypeRequest mocks base method

func (*MockKafkaAPI) UpdateBrokerTypeWithContext 

func (m *MockKafkaAPI) UpdateBrokerTypeWithContext(arg0 context.Context, arg1 *kafka.UpdateBrokerTypeInput, arg2 ...request.Option) (*kafka.UpdateBrokerTypeOutput, error)

UpdateBrokerTypeWithContext mocks base method

func (*MockKafkaAPI) UpdateClusterConfiguration 

func (m *MockKafkaAPI) UpdateClusterConfiguration(arg0 *kafka.UpdateClusterConfigurationInput) (*kafka.UpdateClusterConfigurationOutput, error)

UpdateClusterConfiguration mocks base method

func (*MockKafkaAPI) UpdateClusterConfigurationRequest 

func (m *MockKafkaAPI) UpdateClusterConfigurationRequest(arg0 *kafka.UpdateClusterConfigurationInput) (*request.Request, *kafka.UpdateClusterConfigurationOutput)

UpdateClusterConfigurationRequest mocks base method

func (*MockKafkaAPI) UpdateClusterConfigurationWithContext 

func (m *MockKafkaAPI) UpdateClusterConfigurationWithContext(arg0 context.Context, arg1 *kafka.UpdateClusterConfigurationInput, arg2 ...request.Option) (*kafka.UpdateClusterConfigurationOutput, error)

UpdateClusterConfigurationWithContext mocks base method

func (*MockKafkaAPI) UpdateClusterKafkaVersion 

func (m *MockKafkaAPI) UpdateClusterKafkaVersion(arg0 *kafka.UpdateClusterKafkaVersionInput) (*kafka.UpdateClusterKafkaVersionOutput, error)

UpdateClusterKafkaVersion mocks base method

func (*MockKafkaAPI) UpdateClusterKafkaVersionRequest 

func (m *MockKafkaAPI) UpdateClusterKafkaVersionRequest(arg0 *kafka.UpdateClusterKafkaVersionInput) (*request.Request, *kafka.UpdateClusterKafkaVersionOutput)

UpdateClusterKafkaVersionRequest mocks base method

func (*MockKafkaAPI) UpdateClusterKafkaVersionWithContext 

func (m *MockKafkaAPI) UpdateClusterKafkaVersionWithContext(arg0 context.Context, arg1 *kafka.UpdateClusterKafkaVersionInput, arg2 ...request.Option) (*kafka.UpdateClusterKafkaVersionOutput, error)

UpdateClusterKafkaVersionWithContext mocks base method

func (*MockKafkaAPI) UpdateConfiguration 

func (m *MockKafkaAPI) UpdateConfiguration(arg0 *kafka.UpdateConfigurationInput) (*kafka.UpdateConfigurationOutput, error)

UpdateConfiguration mocks base method

func (*MockKafkaAPI) UpdateConfigurationRequest 

func (m *MockKafkaAPI) UpdateConfigurationRequest(arg0 *kafka.UpdateConfigurationInput) (*request.Request, *kafka.UpdateConfigurationOutput)

UpdateConfigurationRequest mocks base method

func (*MockKafkaAPI) UpdateConfigurationWithContext 

func (m *MockKafkaAPI) UpdateConfigurationWithContext(arg0 context.Context, arg1 *kafka.UpdateConfigurationInput, arg2 ...request.Option) (*kafka.UpdateConfigurationOutput, error)

UpdateConfigurationWithContext mocks base method

func (*MockKafkaAPI) 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

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) DeleteCluster 

func (mr *MockKafkaAPIMockRecorder) DeleteCluster(arg0 interface{}) *gomock.Call

DeleteCluster indicates an expected call of DeleteCluster

func (*MockKafkaAPIMockRecorder) DeleteClusterRequest 

func (mr *MockKafkaAPIMockRecorder) DeleteClusterRequest(arg0 interface{}) *gomock.Call

DeleteClusterRequest indicates an expected call of DeleteClusterRequest

func (*MockKafkaAPIMockRecorder) DeleteClusterWithContext 

func (mr *MockKafkaAPIMockRecorder) DeleteClusterWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DeleteClusterWithContext indicates an expected call of DeleteClusterWithContext

func (*MockKafkaAPIMockRecorder) DeleteConfiguration 

func (mr *MockKafkaAPIMockRecorder) DeleteConfiguration(arg0 interface{}) *gomock.Call

DeleteConfiguration indicates an expected call of DeleteConfiguration

func (*MockKafkaAPIMockRecorder) DeleteConfigurationRequest 

func (mr *MockKafkaAPIMockRecorder) DeleteConfigurationRequest(arg0 interface{}) *gomock.Call

DeleteConfigurationRequest indicates an expected call of DeleteConfigurationRequest

func (*MockKafkaAPIMockRecorder) DeleteConfigurationWithContext 

func (mr *MockKafkaAPIMockRecorder) DeleteConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DeleteConfigurationWithContext indicates an expected call of DeleteConfigurationWithContext

func (*MockKafkaAPIMockRecorder) DescribeCluster 

func (mr *MockKafkaAPIMockRecorder) DescribeCluster(arg0 interface{}) *gomock.Call

DescribeCluster indicates an expected call of DescribeCluster

func (*MockKafkaAPIMockRecorder) DescribeClusterOperation 

func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperation(arg0 interface{}) *gomock.Call

DescribeClusterOperation indicates an expected call of DescribeClusterOperation

func (*MockKafkaAPIMockRecorder) DescribeClusterOperationRequest 

func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationRequest(arg0 interface{}) *gomock.Call

DescribeClusterOperationRequest indicates an expected call of DescribeClusterOperationRequest

func (*MockKafkaAPIMockRecorder) DescribeClusterOperationWithContext 

func (mr *MockKafkaAPIMockRecorder) DescribeClusterOperationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeClusterOperationWithContext indicates an expected call of DescribeClusterOperationWithContext

func (*MockKafkaAPIMockRecorder) DescribeClusterRequest 

func (mr *MockKafkaAPIMockRecorder) DescribeClusterRequest(arg0 interface{}) *gomock.Call

DescribeClusterRequest indicates an expected call of DescribeClusterRequest

func (*MockKafkaAPIMockRecorder) 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) GetBootstrapBrokers 

func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokers(arg0 interface{}) *gomock.Call

GetBootstrapBrokers indicates an expected call of GetBootstrapBrokers

func (*MockKafkaAPIMockRecorder) GetBootstrapBrokersRequest 

func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokersRequest(arg0 interface{}) *gomock.Call

GetBootstrapBrokersRequest indicates an expected call of GetBootstrapBrokersRequest

func (*MockKafkaAPIMockRecorder) GetBootstrapBrokersWithContext 

func (mr *MockKafkaAPIMockRecorder) GetBootstrapBrokersWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetBootstrapBrokersWithContext indicates an expected call of GetBootstrapBrokersWithContext

func (*MockKafkaAPIMockRecorder) GetCompatibleKafkaVersions 

func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersions(arg0 interface{}) *gomock.Call

GetCompatibleKafkaVersions indicates an expected call of GetCompatibleKafkaVersions

func (*MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsRequest 

func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsRequest(arg0 interface{}) *gomock.Call

GetCompatibleKafkaVersionsRequest indicates an expected call of GetCompatibleKafkaVersionsRequest

func (*MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsWithContext 

func (mr *MockKafkaAPIMockRecorder) GetCompatibleKafkaVersionsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetCompatibleKafkaVersionsWithContext indicates an expected call of GetCompatibleKafkaVersionsWithContext

func (*MockKafkaAPIMockRecorder) ListClusterOperations 

func (mr *MockKafkaAPIMockRecorder) ListClusterOperations(arg0 interface{}) *gomock.Call

ListClusterOperations indicates an expected call of ListClusterOperations

func (*MockKafkaAPIMockRecorder) ListClusterOperationsPages 

func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsPages(arg0, arg1 interface{}) *gomock.Call

ListClusterOperationsPages indicates an expected call of ListClusterOperationsPages

func (*MockKafkaAPIMockRecorder) ListClusterOperationsPagesWithContext 

func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

ListClusterOperationsPagesWithContext indicates an expected call of ListClusterOperationsPagesWithContext

func (*MockKafkaAPIMockRecorder) ListClusterOperationsRequest 

func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsRequest(arg0 interface{}) *gomock.Call

ListClusterOperationsRequest indicates an expected call of ListClusterOperationsRequest

func (*MockKafkaAPIMockRecorder) ListClusterOperationsWithContext 

func (mr *MockKafkaAPIMockRecorder) ListClusterOperationsWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListClusterOperationsWithContext indicates an expected call of ListClusterOperationsWithContext

func (*MockKafkaAPIMockRecorder) ListClusters 

func (mr *MockKafkaAPIMockRecorder) ListClusters(arg0 interface{}) *gomock.Call

ListClusters indicates an expected call of ListClusters

func (*MockKafkaAPIMockRecorder) ListClustersPages 

func (mr *MockKafkaAPIMockRecorder) ListClustersPages(arg0, arg1 interface{}) *gomock.Call

ListClustersPages indicates an expected call of ListClustersPages

func (*MockKafkaAPIMockRecorder) ListClustersPagesWithContext 

func (mr *MockKafkaAPIMockRecorder) ListClustersPagesWithContext(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call

ListClustersPagesWithContext indicates an expected call of ListClustersPagesWithContext

func (*MockKafkaAPIMockRecorder) ListClustersRequest 

func (mr *MockKafkaAPIMockRecorder) ListClustersRequest(arg0 interface{}) *gomock.Call

ListClustersRequest indicates an expected call of ListClustersRequest

func (*MockKafkaAPIMockRecorder) 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) RebootBroker 

func (mr *MockKafkaAPIMockRecorder) RebootBroker(arg0 interface{}) *gomock.Call

RebootBroker indicates an expected call of RebootBroker

func (*MockKafkaAPIMockRecorder) RebootBrokerRequest 

func (mr *MockKafkaAPIMockRecorder) RebootBrokerRequest(arg0 interface{}) *gomock.Call

RebootBrokerRequest indicates an expected call of RebootBrokerRequest

func (*MockKafkaAPIMockRecorder) RebootBrokerWithContext 

func (mr *MockKafkaAPIMockRecorder) RebootBrokerWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RebootBrokerWithContext indicates an expected call of RebootBrokerWithContext

func (*MockKafkaAPIMockRecorder) TagResource 

func (mr *MockKafkaAPIMockRecorder) TagResource(arg0 interface{}) *gomock.Call

TagResource indicates an expected call of TagResource

func (*MockKafkaAPIMockRecorder) TagResourceRequest 

func (mr *MockKafkaAPIMockRecorder) TagResourceRequest(arg0 interface{}) *gomock.Call

TagResourceRequest indicates an expected call of TagResourceRequest

func (*MockKafkaAPIMockRecorder) TagResourceWithContext 

func (mr *MockKafkaAPIMockRecorder) TagResourceWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

TagResourceWithContext indicates an expected call of TagResourceWithContext

func (*MockKafkaAPIMockRecorder) UntagResource 

func (mr *MockKafkaAPIMockRecorder) UntagResource(arg0 interface{}) *gomock.Call

UntagResource indicates an expected call of UntagResource

func (*MockKafkaAPIMockRecorder) UntagResourceRequest 

func (mr *MockKafkaAPIMockRecorder) UntagResourceRequest(arg0 interface{}) *gomock.Call

UntagResourceRequest indicates an expected call of UntagResourceRequest

func (*MockKafkaAPIMockRecorder) UntagResourceWithContext 

func (mr *MockKafkaAPIMockRecorder) UntagResourceWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UntagResourceWithContext indicates an expected call of UntagResourceWithContext

func (*MockKafkaAPIMockRecorder) UpdateBrokerCount 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCount(arg0 interface{}) *gomock.Call

UpdateBrokerCount indicates an expected call of UpdateBrokerCount

func (*MockKafkaAPIMockRecorder) UpdateBrokerCountRequest 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCountRequest(arg0 interface{}) *gomock.Call

UpdateBrokerCountRequest indicates an expected call of UpdateBrokerCountRequest

func (*MockKafkaAPIMockRecorder) UpdateBrokerCountWithContext 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerCountWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateBrokerCountWithContext indicates an expected call of UpdateBrokerCountWithContext

func (*MockKafkaAPIMockRecorder) UpdateBrokerStorage 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorage(arg0 interface{}) *gomock.Call

UpdateBrokerStorage indicates an expected call of UpdateBrokerStorage

func (*MockKafkaAPIMockRecorder) UpdateBrokerStorageRequest 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorageRequest(arg0 interface{}) *gomock.Call

UpdateBrokerStorageRequest indicates an expected call of UpdateBrokerStorageRequest

func (*MockKafkaAPIMockRecorder) UpdateBrokerStorageWithContext 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerStorageWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateBrokerStorageWithContext indicates an expected call of UpdateBrokerStorageWithContext

func (*MockKafkaAPIMockRecorder) UpdateBrokerType 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerType(arg0 interface{}) *gomock.Call

UpdateBrokerType indicates an expected call of UpdateBrokerType

func (*MockKafkaAPIMockRecorder) UpdateBrokerTypeRequest 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerTypeRequest(arg0 interface{}) *gomock.Call

UpdateBrokerTypeRequest indicates an expected call of UpdateBrokerTypeRequest

func (*MockKafkaAPIMockRecorder) UpdateBrokerTypeWithContext 

func (mr *MockKafkaAPIMockRecorder) UpdateBrokerTypeWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateBrokerTypeWithContext indicates an expected call of UpdateBrokerTypeWithContext

func (*MockKafkaAPIMockRecorder) UpdateClusterConfiguration 

func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfiguration(arg0 interface{}) *gomock.Call

UpdateClusterConfiguration indicates an expected call of UpdateClusterConfiguration

func (*MockKafkaAPIMockRecorder) UpdateClusterConfigurationRequest 

func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfigurationRequest(arg0 interface{}) *gomock.Call

UpdateClusterConfigurationRequest indicates an expected call of UpdateClusterConfigurationRequest

func (*MockKafkaAPIMockRecorder) UpdateClusterConfigurationWithContext 

func (mr *MockKafkaAPIMockRecorder) UpdateClusterConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateClusterConfigurationWithContext indicates an expected call of UpdateClusterConfigurationWithContext

func (*MockKafkaAPIMockRecorder) UpdateClusterKafkaVersion 

func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersion(arg0 interface{}) *gomock.Call

UpdateClusterKafkaVersion indicates an expected call of UpdateClusterKafkaVersion

func (*MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionRequest 

func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionRequest(arg0 interface{}) *gomock.Call

UpdateClusterKafkaVersionRequest indicates an expected call of UpdateClusterKafkaVersionRequest

func (*MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionWithContext 

func (mr *MockKafkaAPIMockRecorder) UpdateClusterKafkaVersionWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateClusterKafkaVersionWithContext indicates an expected call of UpdateClusterKafkaVersionWithContext

func (*MockKafkaAPIMockRecorder) UpdateConfiguration 

func (mr *MockKafkaAPIMockRecorder) UpdateConfiguration(arg0 interface{}) *gomock.Call

UpdateConfiguration indicates an expected call of UpdateConfiguration

func (*MockKafkaAPIMockRecorder) UpdateConfigurationRequest 

func (mr *MockKafkaAPIMockRecorder) UpdateConfigurationRequest(arg0 interface{}) *gomock.Call

UpdateConfigurationRequest indicates an expected call of UpdateConfigurationRequest

func (*MockKafkaAPIMockRecorder) UpdateConfigurationWithContext 

func (mr *MockKafkaAPIMockRecorder) UpdateConfigurationWithContext(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

UpdateConfigurationWithContext indicates an expected call of UpdateConfigurationWithContext

func (*MockKafkaAPIMockRecorder) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.