mock

package
v0.22.0 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ACLV3Api 

type ACLV3Api struct {
	BatchCreateKafkaAclsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiBatchCreateKafkaAclsRequest

	BatchCreateKafkaAclsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiBatchCreateKafkaAclsRequest) (*net_http.Response, error)

	CreateKafkaAclsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaAclsRequest

	CreateKafkaAclsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaAclsRequest) (*net_http.Response, error)

	DeleteKafkaAclsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaAclsRequest

	DeleteKafkaAclsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaAclsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.InlineResponse200, *net_http.Response, error)

	GetKafkaAclsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaAclsRequest

	GetKafkaAclsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaAclsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AclDataList, *net_http.Response, error)
	// contains filtered or unexported fields
}

ACLV3Api is a mock of ACLV3Api interface

func (*ACLV3Api) BatchCreateKafkaAcls added in v0.14.0 

func (m *ACLV3Api) BatchCreateKafkaAcls(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiBatchCreateKafkaAclsRequest

BatchCreateKafkaAcls mocks base method by wrapping the associated func.

func (*ACLV3Api) BatchCreateKafkaAclsCalled added in v0.14.0 

func (m *ACLV3Api) BatchCreateKafkaAclsCalled() bool

BatchCreateKafkaAclsCalled returns true if BatchCreateKafkaAcls was called at least once.

func (*ACLV3Api) BatchCreateKafkaAclsCalls added in v0.14.0 

func (m *ACLV3Api) BatchCreateKafkaAclsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

BatchCreateKafkaAclsCalls returns the calls made to BatchCreateKafkaAcls.

func (*ACLV3Api) BatchCreateKafkaAclsExecute added in v0.14.0 

func (m *ACLV3Api) BatchCreateKafkaAclsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiBatchCreateKafkaAclsRequest) (*net_http.Response, error)

BatchCreateKafkaAclsExecute mocks base method by wrapping the associated func.

func (*ACLV3Api) BatchCreateKafkaAclsExecuteCalled added in v0.14.0 

func (m *ACLV3Api) BatchCreateKafkaAclsExecuteCalled() bool

BatchCreateKafkaAclsExecuteCalled returns true if BatchCreateKafkaAclsExecute was called at least once.

func (*ACLV3Api) BatchCreateKafkaAclsExecuteCalls added in v0.14.0 

func (m *ACLV3Api) BatchCreateKafkaAclsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiBatchCreateKafkaAclsRequest
}

BatchCreateKafkaAclsExecuteCalls returns the calls made to BatchCreateKafkaAclsExecute.

func (*ACLV3Api) CreateKafkaAcls 

func (m *ACLV3Api) CreateKafkaAcls(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaAclsRequest

CreateKafkaAcls mocks base method by wrapping the associated func.

func (*ACLV3Api) CreateKafkaAclsCalled 

func (m *ACLV3Api) CreateKafkaAclsCalled() bool

CreateKafkaAclsCalled returns true if CreateKafkaAcls was called at least once.

func (*ACLV3Api) CreateKafkaAclsCalls 

func (m *ACLV3Api) CreateKafkaAclsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

CreateKafkaAclsCalls returns the calls made to CreateKafkaAcls.

func (*ACLV3Api) CreateKafkaAclsExecute 

func (m *ACLV3Api) CreateKafkaAclsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaAclsRequest) (*net_http.Response, error)

CreateKafkaAclsExecute mocks base method by wrapping the associated func.

func (*ACLV3Api) CreateKafkaAclsExecuteCalled 

func (m *ACLV3Api) CreateKafkaAclsExecuteCalled() bool

CreateKafkaAclsExecuteCalled returns true if CreateKafkaAclsExecute was called at least once.

func (*ACLV3Api) CreateKafkaAclsExecuteCalls 

func (m *ACLV3Api) CreateKafkaAclsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaAclsRequest
}

CreateKafkaAclsExecuteCalls returns the calls made to CreateKafkaAclsExecute.

func (*ACLV3Api) DeleteKafkaAcls 

func (m *ACLV3Api) DeleteKafkaAcls(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaAclsRequest

DeleteKafkaAcls mocks base method by wrapping the associated func.

func (*ACLV3Api) DeleteKafkaAclsCalled 

func (m *ACLV3Api) DeleteKafkaAclsCalled() bool

DeleteKafkaAclsCalled returns true if DeleteKafkaAcls was called at least once.

func (*ACLV3Api) DeleteKafkaAclsCalls 

func (m *ACLV3Api) DeleteKafkaAclsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

DeleteKafkaAclsCalls returns the calls made to DeleteKafkaAcls.

func (*ACLV3Api) DeleteKafkaAclsExecute 

func (m *ACLV3Api) DeleteKafkaAclsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaAclsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.InlineResponse200, *net_http.Response, error)

DeleteKafkaAclsExecute mocks base method by wrapping the associated func.

func (*ACLV3Api) DeleteKafkaAclsExecuteCalled 

func (m *ACLV3Api) DeleteKafkaAclsExecuteCalled() bool

DeleteKafkaAclsExecuteCalled returns true if DeleteKafkaAclsExecute was called at least once.

func (*ACLV3Api) DeleteKafkaAclsExecuteCalls 

func (m *ACLV3Api) DeleteKafkaAclsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaAclsRequest
}

DeleteKafkaAclsExecuteCalls returns the calls made to DeleteKafkaAclsExecute.

func (*ACLV3Api) GetKafkaAcls 

func (m *ACLV3Api) GetKafkaAcls(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaAclsRequest

GetKafkaAcls mocks base method by wrapping the associated func.

func (*ACLV3Api) GetKafkaAclsCalled 

func (m *ACLV3Api) GetKafkaAclsCalled() bool

GetKafkaAclsCalled returns true if GetKafkaAcls was called at least once.

func (*ACLV3Api) GetKafkaAclsCalls 

func (m *ACLV3Api) GetKafkaAclsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

GetKafkaAclsCalls returns the calls made to GetKafkaAcls.

func (*ACLV3Api) GetKafkaAclsExecute 

func (m *ACLV3Api) GetKafkaAclsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaAclsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AclDataList, *net_http.Response, error)

GetKafkaAclsExecute mocks base method by wrapping the associated func.

func (*ACLV3Api) GetKafkaAclsExecuteCalled 

func (m *ACLV3Api) GetKafkaAclsExecuteCalled() bool

GetKafkaAclsExecuteCalled returns true if GetKafkaAclsExecute was called at least once.

func (*ACLV3Api) GetKafkaAclsExecuteCalls 

func (m *ACLV3Api) GetKafkaAclsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaAclsRequest
}

GetKafkaAclsExecuteCalls returns the calls made to GetKafkaAclsExecute.

func (*ACLV3Api) Reset 

func (m *ACLV3Api) Reset()

Reset resets the calls made to the mocked methods.

type ClusterLinkingV3Api 

type ClusterLinkingV3Api struct {
	CreateKafkaLinkFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaLinkRequest

	CreateKafkaLinkExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaLinkRequest) (*net_http.Response, error)

	CreateKafkaMirrorTopicFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaMirrorTopicRequest

	CreateKafkaMirrorTopicExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaMirrorTopicRequest) (*net_http.Response, error)

	DeleteKafkaLinkFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkRequest

	DeleteKafkaLinkExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkRequest) (*net_http.Response, error)

	DeleteKafkaLinkConfigFunc func(ctx context.Context, clusterId, linkName, configName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkConfigRequest

	DeleteKafkaLinkConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkConfigRequest) (*net_http.Response, error)

	GetKafkaLinkFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkRequest

	GetKafkaLinkExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListLinksResponseData, *net_http.Response, error)

	GetKafkaLinkConfigsFunc func(ctx context.Context, clusterId, linkName, configName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkConfigsRequest

	GetKafkaLinkConfigsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListLinkConfigsResponseData, *net_http.Response, error)

	ListKafkaLinkConfigsFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinkConfigsRequest

	ListKafkaLinkConfigsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinkConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListLinkConfigsResponseDataList, *net_http.Response, error)

	ListKafkaLinksFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinksRequest

	ListKafkaLinksExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinksRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListLinksResponseDataList, *net_http.Response, error)

	ListKafkaMirrorTopicsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsRequest

	ListKafkaMirrorTopicsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListMirrorTopicsResponseDataList, *net_http.Response, error)

	ListKafkaMirrorTopicsUnderLinkFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsUnderLinkRequest

	ListKafkaMirrorTopicsUnderLinkExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsUnderLinkRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListMirrorTopicsResponseDataList, *net_http.Response, error)

	ReadKafkaMirrorTopicFunc func(ctx context.Context, clusterId, linkName, mirrorTopicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiReadKafkaMirrorTopicRequest

	ReadKafkaMirrorTopicExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiReadKafkaMirrorTopicRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListMirrorTopicsResponseData, *net_http.Response, error)

	UpdateKafkaLinkConfigFunc func(ctx context.Context, clusterId, linkName, configName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigRequest

	UpdateKafkaLinkConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigRequest) (*net_http.Response, error)

	UpdateKafkaLinkConfigBatchFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigBatchRequest

	UpdateKafkaLinkConfigBatchExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigBatchRequest) (*net_http.Response, error)

	UpdateKafkaMirrorTopicsFailoverFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsFailoverRequest

	UpdateKafkaMirrorTopicsFailoverExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsFailoverRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

	UpdateKafkaMirrorTopicsPauseFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPauseRequest

	UpdateKafkaMirrorTopicsPauseExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPauseRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

	UpdateKafkaMirrorTopicsPromoteFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPromoteRequest

	UpdateKafkaMirrorTopicsPromoteExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPromoteRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

	UpdateKafkaMirrorTopicsResumeFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsResumeRequest

	UpdateKafkaMirrorTopicsResumeExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsResumeRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

	UpdateKafkaMirrorTopicsReverseAndPauseMirrorFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndPauseMirrorRequest

	UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndPauseMirrorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

	UpdateKafkaMirrorTopicsReverseAndStartMirrorFunc func(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndStartMirrorRequest

	UpdateKafkaMirrorTopicsReverseAndStartMirrorExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndStartMirrorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)
	// contains filtered or unexported fields
}

ClusterLinkingV3Api is a mock of ClusterLinkingV3Api interface 

func (m *ClusterLinkingV3Api) CreateKafkaLink(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaLinkRequest

CreateKafkaLink mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) CreateKafkaLinkCalled 

func (m *ClusterLinkingV3Api) CreateKafkaLinkCalled() bool

CreateKafkaLinkCalled returns true if CreateKafkaLink was called at least once.

func (*ClusterLinkingV3Api) CreateKafkaLinkCalls 

func (m *ClusterLinkingV3Api) CreateKafkaLinkCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

CreateKafkaLinkCalls returns the calls made to CreateKafkaLink.

func (*ClusterLinkingV3Api) CreateKafkaLinkExecute 

func (m *ClusterLinkingV3Api) CreateKafkaLinkExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaLinkRequest) (*net_http.Response, error)

CreateKafkaLinkExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) CreateKafkaLinkExecuteCalled 

func (m *ClusterLinkingV3Api) CreateKafkaLinkExecuteCalled() bool

CreateKafkaLinkExecuteCalled returns true if CreateKafkaLinkExecute was called at least once.

func (*ClusterLinkingV3Api) CreateKafkaLinkExecuteCalls 

func (m *ClusterLinkingV3Api) CreateKafkaLinkExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaLinkRequest
}

CreateKafkaLinkExecuteCalls returns the calls made to CreateKafkaLinkExecute.

func (*ClusterLinkingV3Api) CreateKafkaMirrorTopic 

func (m *ClusterLinkingV3Api) CreateKafkaMirrorTopic(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaMirrorTopicRequest

CreateKafkaMirrorTopic mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) CreateKafkaMirrorTopicCalled 

func (m *ClusterLinkingV3Api) CreateKafkaMirrorTopicCalled() bool

CreateKafkaMirrorTopicCalled returns true if CreateKafkaMirrorTopic was called at least once.

func (*ClusterLinkingV3Api) CreateKafkaMirrorTopicCalls 

func (m *ClusterLinkingV3Api) CreateKafkaMirrorTopicCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

CreateKafkaMirrorTopicCalls returns the calls made to CreateKafkaMirrorTopic.

func (*ClusterLinkingV3Api) CreateKafkaMirrorTopicExecute 

func (m *ClusterLinkingV3Api) CreateKafkaMirrorTopicExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaMirrorTopicRequest) (*net_http.Response, error)

CreateKafkaMirrorTopicExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) CreateKafkaMirrorTopicExecuteCalled 

func (m *ClusterLinkingV3Api) CreateKafkaMirrorTopicExecuteCalled() bool

CreateKafkaMirrorTopicExecuteCalled returns true if CreateKafkaMirrorTopicExecute was called at least once.

func (*ClusterLinkingV3Api) CreateKafkaMirrorTopicExecuteCalls 

func (m *ClusterLinkingV3Api) CreateKafkaMirrorTopicExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaMirrorTopicRequest
}

CreateKafkaMirrorTopicExecuteCalls returns the calls made to CreateKafkaMirrorTopicExecute. 

func (m *ClusterLinkingV3Api) DeleteKafkaLink(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkRequest

DeleteKafkaLink mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) DeleteKafkaLinkCalled 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkCalled() bool

DeleteKafkaLinkCalled returns true if DeleteKafkaLink was called at least once.

func (*ClusterLinkingV3Api) DeleteKafkaLinkCalls 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

DeleteKafkaLinkCalls returns the calls made to DeleteKafkaLink.

func (*ClusterLinkingV3Api) DeleteKafkaLinkConfig 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkConfig(ctx context.Context, clusterId, linkName, configName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkConfigRequest

DeleteKafkaLinkConfig mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) DeleteKafkaLinkConfigCalled 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkConfigCalled() bool

DeleteKafkaLinkConfigCalled returns true if DeleteKafkaLinkConfig was called at least once.

func (*ClusterLinkingV3Api) DeleteKafkaLinkConfigCalls 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkConfigCalls() []struct {
	Ctx        context.Context
	ClusterId  string
	LinkName   string
	ConfigName string
}

DeleteKafkaLinkConfigCalls returns the calls made to DeleteKafkaLinkConfig.

func (*ClusterLinkingV3Api) DeleteKafkaLinkConfigExecute 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkConfigRequest) (*net_http.Response, error)

DeleteKafkaLinkConfigExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) DeleteKafkaLinkConfigExecuteCalled 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkConfigExecuteCalled() bool

DeleteKafkaLinkConfigExecuteCalled returns true if DeleteKafkaLinkConfigExecute was called at least once.

func (*ClusterLinkingV3Api) DeleteKafkaLinkConfigExecuteCalls 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkConfigRequest
}

DeleteKafkaLinkConfigExecuteCalls returns the calls made to DeleteKafkaLinkConfigExecute.

func (*ClusterLinkingV3Api) DeleteKafkaLinkExecute 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkRequest) (*net_http.Response, error)

DeleteKafkaLinkExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) DeleteKafkaLinkExecuteCalled 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkExecuteCalled() bool

DeleteKafkaLinkExecuteCalled returns true if DeleteKafkaLinkExecute was called at least once.

func (*ClusterLinkingV3Api) DeleteKafkaLinkExecuteCalls 

func (m *ClusterLinkingV3Api) DeleteKafkaLinkExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaLinkRequest
}

DeleteKafkaLinkExecuteCalls returns the calls made to DeleteKafkaLinkExecute. 

func (m *ClusterLinkingV3Api) GetKafkaLink(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkRequest

GetKafkaLink mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) GetKafkaLinkCalled 

func (m *ClusterLinkingV3Api) GetKafkaLinkCalled() bool

GetKafkaLinkCalled returns true if GetKafkaLink was called at least once.

func (*ClusterLinkingV3Api) GetKafkaLinkCalls 

func (m *ClusterLinkingV3Api) GetKafkaLinkCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

GetKafkaLinkCalls returns the calls made to GetKafkaLink.

func (*ClusterLinkingV3Api) GetKafkaLinkConfigs 

func (m *ClusterLinkingV3Api) GetKafkaLinkConfigs(ctx context.Context, clusterId, linkName, configName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkConfigsRequest

GetKafkaLinkConfigs mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) GetKafkaLinkConfigsCalled 

func (m *ClusterLinkingV3Api) GetKafkaLinkConfigsCalled() bool

GetKafkaLinkConfigsCalled returns true if GetKafkaLinkConfigs was called at least once.

func (*ClusterLinkingV3Api) GetKafkaLinkConfigsCalls 

func (m *ClusterLinkingV3Api) GetKafkaLinkConfigsCalls() []struct {
	Ctx        context.Context
	ClusterId  string
	LinkName   string
	ConfigName string
}

GetKafkaLinkConfigsCalls returns the calls made to GetKafkaLinkConfigs.

func (*ClusterLinkingV3Api) GetKafkaLinkConfigsExecute 

func (m *ClusterLinkingV3Api) GetKafkaLinkConfigsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListLinkConfigsResponseData, *net_http.Response, error)

GetKafkaLinkConfigsExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) GetKafkaLinkConfigsExecuteCalled 

func (m *ClusterLinkingV3Api) GetKafkaLinkConfigsExecuteCalled() bool

GetKafkaLinkConfigsExecuteCalled returns true if GetKafkaLinkConfigsExecute was called at least once.

func (*ClusterLinkingV3Api) GetKafkaLinkConfigsExecuteCalls 

func (m *ClusterLinkingV3Api) GetKafkaLinkConfigsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkConfigsRequest
}

GetKafkaLinkConfigsExecuteCalls returns the calls made to GetKafkaLinkConfigsExecute.

func (*ClusterLinkingV3Api) GetKafkaLinkExecute 

func (m *ClusterLinkingV3Api) GetKafkaLinkExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListLinksResponseData, *net_http.Response, error)

GetKafkaLinkExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) GetKafkaLinkExecuteCalled 

func (m *ClusterLinkingV3Api) GetKafkaLinkExecuteCalled() bool

GetKafkaLinkExecuteCalled returns true if GetKafkaLinkExecute was called at least once.

func (*ClusterLinkingV3Api) GetKafkaLinkExecuteCalls 

func (m *ClusterLinkingV3Api) GetKafkaLinkExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaLinkRequest
}

GetKafkaLinkExecuteCalls returns the calls made to GetKafkaLinkExecute.

func (*ClusterLinkingV3Api) ListKafkaLinkConfigs 

func (m *ClusterLinkingV3Api) ListKafkaLinkConfigs(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinkConfigsRequest

ListKafkaLinkConfigs mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ListKafkaLinkConfigsCalled 

func (m *ClusterLinkingV3Api) ListKafkaLinkConfigsCalled() bool

ListKafkaLinkConfigsCalled returns true if ListKafkaLinkConfigs was called at least once.

func (*ClusterLinkingV3Api) ListKafkaLinkConfigsCalls 

func (m *ClusterLinkingV3Api) ListKafkaLinkConfigsCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

ListKafkaLinkConfigsCalls returns the calls made to ListKafkaLinkConfigs.

func (*ClusterLinkingV3Api) ListKafkaLinkConfigsExecute 

func (m *ClusterLinkingV3Api) ListKafkaLinkConfigsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinkConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListLinkConfigsResponseDataList, *net_http.Response, error)

ListKafkaLinkConfigsExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ListKafkaLinkConfigsExecuteCalled 

func (m *ClusterLinkingV3Api) ListKafkaLinkConfigsExecuteCalled() bool

ListKafkaLinkConfigsExecuteCalled returns true if ListKafkaLinkConfigsExecute was called at least once.

func (*ClusterLinkingV3Api) ListKafkaLinkConfigsExecuteCalls 

func (m *ClusterLinkingV3Api) ListKafkaLinkConfigsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinkConfigsRequest
}

ListKafkaLinkConfigsExecuteCalls returns the calls made to ListKafkaLinkConfigsExecute. 

func (m *ClusterLinkingV3Api) ListKafkaLinks(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinksRequest

ListKafkaLinks mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ListKafkaLinksCalled 

func (m *ClusterLinkingV3Api) ListKafkaLinksCalled() bool

ListKafkaLinksCalled returns true if ListKafkaLinks was called at least once.

func (*ClusterLinkingV3Api) ListKafkaLinksCalls 

func (m *ClusterLinkingV3Api) ListKafkaLinksCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

ListKafkaLinksCalls returns the calls made to ListKafkaLinks.

func (*ClusterLinkingV3Api) ListKafkaLinksExecute 

func (m *ClusterLinkingV3Api) ListKafkaLinksExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinksRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListLinksResponseDataList, *net_http.Response, error)

ListKafkaLinksExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ListKafkaLinksExecuteCalled 

func (m *ClusterLinkingV3Api) ListKafkaLinksExecuteCalled() bool

ListKafkaLinksExecuteCalled returns true if ListKafkaLinksExecute was called at least once.

func (*ClusterLinkingV3Api) ListKafkaLinksExecuteCalls 

func (m *ClusterLinkingV3Api) ListKafkaLinksExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaLinksRequest
}

ListKafkaLinksExecuteCalls returns the calls made to ListKafkaLinksExecute.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopics 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopics(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsRequest

ListKafkaMirrorTopics mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsCalled 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsCalled() bool

ListKafkaMirrorTopicsCalled returns true if ListKafkaMirrorTopics was called at least once.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsCalls 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

ListKafkaMirrorTopicsCalls returns the calls made to ListKafkaMirrorTopics.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsExecute 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListMirrorTopicsResponseDataList, *net_http.Response, error)

ListKafkaMirrorTopicsExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsExecuteCalled 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsExecuteCalled() bool

ListKafkaMirrorTopicsExecuteCalled returns true if ListKafkaMirrorTopicsExecute was called at least once.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsExecuteCalls 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsRequest
}

ListKafkaMirrorTopicsExecuteCalls returns the calls made to ListKafkaMirrorTopicsExecute. 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLink(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsUnderLinkRequest

ListKafkaMirrorTopicsUnderLink mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkCalled 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkCalled() bool

ListKafkaMirrorTopicsUnderLinkCalled returns true if ListKafkaMirrorTopicsUnderLink was called at least once.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkCalls 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

ListKafkaMirrorTopicsUnderLinkCalls returns the calls made to ListKafkaMirrorTopicsUnderLink.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkExecute 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsUnderLinkRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListMirrorTopicsResponseDataList, *net_http.Response, error)

ListKafkaMirrorTopicsUnderLinkExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkExecuteCalled 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkExecuteCalled() bool

ListKafkaMirrorTopicsUnderLinkExecuteCalled returns true if ListKafkaMirrorTopicsUnderLinkExecute was called at least once.

func (*ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkExecuteCalls 

func (m *ClusterLinkingV3Api) ListKafkaMirrorTopicsUnderLinkExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaMirrorTopicsUnderLinkRequest
}

ListKafkaMirrorTopicsUnderLinkExecuteCalls returns the calls made to ListKafkaMirrorTopicsUnderLinkExecute.

func (*ClusterLinkingV3Api) ReadKafkaMirrorTopic 

func (m *ClusterLinkingV3Api) ReadKafkaMirrorTopic(ctx context.Context, clusterId, linkName, mirrorTopicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiReadKafkaMirrorTopicRequest

ReadKafkaMirrorTopic mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ReadKafkaMirrorTopicCalled 

func (m *ClusterLinkingV3Api) ReadKafkaMirrorTopicCalled() bool

ReadKafkaMirrorTopicCalled returns true if ReadKafkaMirrorTopic was called at least once.

func (*ClusterLinkingV3Api) ReadKafkaMirrorTopicCalls 

func (m *ClusterLinkingV3Api) ReadKafkaMirrorTopicCalls() []struct {
	Ctx             context.Context
	ClusterId       string
	LinkName        string
	MirrorTopicName string
}

ReadKafkaMirrorTopicCalls returns the calls made to ReadKafkaMirrorTopic.

func (*ClusterLinkingV3Api) ReadKafkaMirrorTopicExecute 

func (m *ClusterLinkingV3Api) ReadKafkaMirrorTopicExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiReadKafkaMirrorTopicRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ListMirrorTopicsResponseData, *net_http.Response, error)

ReadKafkaMirrorTopicExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) ReadKafkaMirrorTopicExecuteCalled 

func (m *ClusterLinkingV3Api) ReadKafkaMirrorTopicExecuteCalled() bool

ReadKafkaMirrorTopicExecuteCalled returns true if ReadKafkaMirrorTopicExecute was called at least once.

func (*ClusterLinkingV3Api) ReadKafkaMirrorTopicExecuteCalls 

func (m *ClusterLinkingV3Api) ReadKafkaMirrorTopicExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiReadKafkaMirrorTopicRequest
}

ReadKafkaMirrorTopicExecuteCalls returns the calls made to ReadKafkaMirrorTopicExecute.

func (*ClusterLinkingV3Api) Reset 

func (m *ClusterLinkingV3Api) Reset()

Reset resets the calls made to the mocked methods.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfig 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfig(ctx context.Context, clusterId, linkName, configName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigRequest

UpdateKafkaLinkConfig mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigBatch 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigBatch(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigBatchRequest

UpdateKafkaLinkConfigBatch mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchCalled() bool

UpdateKafkaLinkConfigBatchCalled returns true if UpdateKafkaLinkConfigBatch was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

UpdateKafkaLinkConfigBatchCalls returns the calls made to UpdateKafkaLinkConfigBatch.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchExecute 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigBatchRequest) (*net_http.Response, error)

UpdateKafkaLinkConfigBatchExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchExecuteCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchExecuteCalled() bool

UpdateKafkaLinkConfigBatchExecuteCalled returns true if UpdateKafkaLinkConfigBatchExecute was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchExecuteCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigBatchExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigBatchRequest
}

UpdateKafkaLinkConfigBatchExecuteCalls returns the calls made to UpdateKafkaLinkConfigBatchExecute.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigCalled() bool

UpdateKafkaLinkConfigCalled returns true if UpdateKafkaLinkConfig was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigCalls() []struct {
	Ctx        context.Context
	ClusterId  string
	LinkName   string
	ConfigName string
}

UpdateKafkaLinkConfigCalls returns the calls made to UpdateKafkaLinkConfig.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigExecute 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigRequest) (*net_http.Response, error)

UpdateKafkaLinkConfigExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigExecuteCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigExecuteCalled() bool

UpdateKafkaLinkConfigExecuteCalled returns true if UpdateKafkaLinkConfigExecute was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaLinkConfigExecuteCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaLinkConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaLinkConfigRequest
}

UpdateKafkaLinkConfigExecuteCalls returns the calls made to UpdateKafkaLinkConfigExecute.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailover 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailover(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsFailoverRequest

UpdateKafkaMirrorTopicsFailover mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverCalled() bool

UpdateKafkaMirrorTopicsFailoverCalled returns true if UpdateKafkaMirrorTopicsFailover was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

UpdateKafkaMirrorTopicsFailoverCalls returns the calls made to UpdateKafkaMirrorTopicsFailover.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverExecute 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsFailoverRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

UpdateKafkaMirrorTopicsFailoverExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverExecuteCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverExecuteCalled() bool

UpdateKafkaMirrorTopicsFailoverExecuteCalled returns true if UpdateKafkaMirrorTopicsFailoverExecute was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverExecuteCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsFailoverExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsFailoverRequest
}

UpdateKafkaMirrorTopicsFailoverExecuteCalls returns the calls made to UpdateKafkaMirrorTopicsFailoverExecute.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPause 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPause(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPauseRequest

UpdateKafkaMirrorTopicsPause mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseCalled() bool

UpdateKafkaMirrorTopicsPauseCalled returns true if UpdateKafkaMirrorTopicsPause was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

UpdateKafkaMirrorTopicsPauseCalls returns the calls made to UpdateKafkaMirrorTopicsPause.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseExecute 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPauseRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

UpdateKafkaMirrorTopicsPauseExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseExecuteCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseExecuteCalled() bool

UpdateKafkaMirrorTopicsPauseExecuteCalled returns true if UpdateKafkaMirrorTopicsPauseExecute was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseExecuteCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPauseExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPauseRequest
}

UpdateKafkaMirrorTopicsPauseExecuteCalls returns the calls made to UpdateKafkaMirrorTopicsPauseExecute.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromote 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromote(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPromoteRequest

UpdateKafkaMirrorTopicsPromote mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteCalled() bool

UpdateKafkaMirrorTopicsPromoteCalled returns true if UpdateKafkaMirrorTopicsPromote was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

UpdateKafkaMirrorTopicsPromoteCalls returns the calls made to UpdateKafkaMirrorTopicsPromote.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteExecute 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPromoteRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

UpdateKafkaMirrorTopicsPromoteExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteExecuteCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteExecuteCalled() bool

UpdateKafkaMirrorTopicsPromoteExecuteCalled returns true if UpdateKafkaMirrorTopicsPromoteExecute was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteExecuteCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsPromoteExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsPromoteRequest
}

UpdateKafkaMirrorTopicsPromoteExecuteCalls returns the calls made to UpdateKafkaMirrorTopicsPromoteExecute.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResume 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResume(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsResumeRequest

UpdateKafkaMirrorTopicsResume mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeCalled() bool

UpdateKafkaMirrorTopicsResumeCalled returns true if UpdateKafkaMirrorTopicsResume was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

UpdateKafkaMirrorTopicsResumeCalls returns the calls made to UpdateKafkaMirrorTopicsResume.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeExecute 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsResumeRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

UpdateKafkaMirrorTopicsResumeExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeExecuteCalled 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeExecuteCalled() bool

UpdateKafkaMirrorTopicsResumeExecuteCalled returns true if UpdateKafkaMirrorTopicsResumeExecute was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeExecuteCalls 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsResumeExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsResumeRequest
}

UpdateKafkaMirrorTopicsResumeExecuteCalls returns the calls made to UpdateKafkaMirrorTopicsResumeExecute.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirror added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirror(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndPauseMirrorRequest

UpdateKafkaMirrorTopicsReverseAndPauseMirror mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorCalled added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorCalled() bool

UpdateKafkaMirrorTopicsReverseAndPauseMirrorCalled returns true if UpdateKafkaMirrorTopicsReverseAndPauseMirror was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorCalls added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

UpdateKafkaMirrorTopicsReverseAndPauseMirrorCalls returns the calls made to UpdateKafkaMirrorTopicsReverseAndPauseMirror.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecute added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndPauseMirrorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecuteCalled added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecuteCalled() bool

UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecuteCalled returns true if UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecute was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecuteCalls added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndPauseMirrorRequest
}

UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecuteCalls returns the calls made to UpdateKafkaMirrorTopicsReverseAndPauseMirrorExecute.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirror added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirror(ctx context.Context, clusterId, linkName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndStartMirrorRequest

UpdateKafkaMirrorTopicsReverseAndStartMirror mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorCalled added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorCalled() bool

UpdateKafkaMirrorTopicsReverseAndStartMirrorCalled returns true if UpdateKafkaMirrorTopicsReverseAndStartMirror was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorCalls added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorCalls() []struct {
	Ctx       context.Context
	ClusterId string
	LinkName  string
}

UpdateKafkaMirrorTopicsReverseAndStartMirrorCalls returns the calls made to UpdateKafkaMirrorTopicsReverseAndStartMirror.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorExecute added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndStartMirrorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.AlterMirrorStatusResponseDataList, *net_http.Response, error)

UpdateKafkaMirrorTopicsReverseAndStartMirrorExecute mocks base method by wrapping the associated func.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorExecuteCalled added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorExecuteCalled() bool

UpdateKafkaMirrorTopicsReverseAndStartMirrorExecuteCalled returns true if UpdateKafkaMirrorTopicsReverseAndStartMirrorExecute was called at least once.

func (*ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorExecuteCalls added in v0.17.0 

func (m *ClusterLinkingV3Api) UpdateKafkaMirrorTopicsReverseAndStartMirrorExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaMirrorTopicsReverseAndStartMirrorRequest
}

UpdateKafkaMirrorTopicsReverseAndStartMirrorExecuteCalls returns the calls made to UpdateKafkaMirrorTopicsReverseAndStartMirrorExecute.

type ClusterV3Api 

type ClusterV3Api struct {
	GetKafkaClusterFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterRequest

	GetKafkaClusterExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ClusterData, *net_http.Response, error)
	// contains filtered or unexported fields
}

ClusterV3Api is a mock of ClusterV3Api interface

func (*ClusterV3Api) GetKafkaCluster 

func (m *ClusterV3Api) GetKafkaCluster(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterRequest

GetKafkaCluster mocks base method by wrapping the associated func.

func (*ClusterV3Api) GetKafkaClusterCalled 

func (m *ClusterV3Api) GetKafkaClusterCalled() bool

GetKafkaClusterCalled returns true if GetKafkaCluster was called at least once.

func (*ClusterV3Api) GetKafkaClusterCalls 

func (m *ClusterV3Api) GetKafkaClusterCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

GetKafkaClusterCalls returns the calls made to GetKafkaCluster.

func (*ClusterV3Api) GetKafkaClusterExecute 

func (m *ClusterV3Api) GetKafkaClusterExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ClusterData, *net_http.Response, error)

GetKafkaClusterExecute mocks base method by wrapping the associated func.

func (*ClusterV3Api) GetKafkaClusterExecuteCalled 

func (m *ClusterV3Api) GetKafkaClusterExecuteCalled() bool

GetKafkaClusterExecuteCalled returns true if GetKafkaClusterExecute was called at least once.

func (*ClusterV3Api) GetKafkaClusterExecuteCalls 

func (m *ClusterV3Api) GetKafkaClusterExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterRequest
}

GetKafkaClusterExecuteCalls returns the calls made to GetKafkaClusterExecute.

func (*ClusterV3Api) Reset 

func (m *ClusterV3Api) Reset()

Reset resets the calls made to the mocked methods.

type ConfigsV3Api 

type ConfigsV3Api struct {
	DeleteKafkaClusterConfigFunc func(ctx context.Context, clusterId, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaClusterConfigRequest

	DeleteKafkaClusterConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaClusterConfigRequest) (*net_http.Response, error)

	DeleteKafkaTopicConfigFunc func(ctx context.Context, clusterId, topicName, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicConfigRequest

	DeleteKafkaTopicConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicConfigRequest) (*net_http.Response, error)

	GetKafkaClusterConfigFunc func(ctx context.Context, clusterId, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterConfigRequest

	GetKafkaClusterConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterConfigRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ClusterConfigData, *net_http.Response, error)

	GetKafkaTopicConfigFunc func(ctx context.Context, clusterId, topicName, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicConfigRequest

	GetKafkaTopicConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicConfigRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicConfigData, *net_http.Response, error)

	ListKafkaAllTopicConfigsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaAllTopicConfigsRequest

	ListKafkaAllTopicConfigsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaAllTopicConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicConfigDataList, *net_http.Response, error)

	ListKafkaClusterConfigsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaClusterConfigsRequest

	ListKafkaClusterConfigsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaClusterConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ClusterConfigDataList, *net_http.Response, error)

	ListKafkaDefaultTopicConfigsFunc func(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaDefaultTopicConfigsRequest

	ListKafkaDefaultTopicConfigsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaDefaultTopicConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicConfigDataList, *net_http.Response, error)

	ListKafkaTopicConfigsFunc func(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicConfigsRequest

	ListKafkaTopicConfigsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicConfigDataList, *net_http.Response, error)

	UpdateKafkaClusterConfigFunc func(ctx context.Context, clusterId, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigRequest

	UpdateKafkaClusterConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigRequest) (*net_http.Response, error)

	UpdateKafkaClusterConfigsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigsRequest

	UpdateKafkaClusterConfigsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigsRequest) (*net_http.Response, error)

	UpdateKafkaTopicConfigFunc func(ctx context.Context, clusterId, topicName, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigRequest

	UpdateKafkaTopicConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigRequest) (*net_http.Response, error)

	UpdateKafkaTopicConfigBatchFunc func(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigBatchRequest

	UpdateKafkaTopicConfigBatchExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigBatchRequest) (*net_http.Response, error)
	// contains filtered or unexported fields
}

ConfigsV3Api is a mock of ConfigsV3Api interface

func (*ConfigsV3Api) DeleteKafkaClusterConfig 

func (m *ConfigsV3Api) DeleteKafkaClusterConfig(ctx context.Context, clusterId, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaClusterConfigRequest

DeleteKafkaClusterConfig mocks base method by wrapping the associated func.

func (*ConfigsV3Api) DeleteKafkaClusterConfigCalled 

func (m *ConfigsV3Api) DeleteKafkaClusterConfigCalled() bool

DeleteKafkaClusterConfigCalled returns true if DeleteKafkaClusterConfig was called at least once.

func (*ConfigsV3Api) DeleteKafkaClusterConfigCalls 

func (m *ConfigsV3Api) DeleteKafkaClusterConfigCalls() []struct {
	Ctx       context.Context
	ClusterId string
	Name      string
}

DeleteKafkaClusterConfigCalls returns the calls made to DeleteKafkaClusterConfig.

func (*ConfigsV3Api) DeleteKafkaClusterConfigExecute 

func (m *ConfigsV3Api) DeleteKafkaClusterConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaClusterConfigRequest) (*net_http.Response, error)

DeleteKafkaClusterConfigExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) DeleteKafkaClusterConfigExecuteCalled 

func (m *ConfigsV3Api) DeleteKafkaClusterConfigExecuteCalled() bool

DeleteKafkaClusterConfigExecuteCalled returns true if DeleteKafkaClusterConfigExecute was called at least once.

func (*ConfigsV3Api) DeleteKafkaClusterConfigExecuteCalls 

func (m *ConfigsV3Api) DeleteKafkaClusterConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaClusterConfigRequest
}

DeleteKafkaClusterConfigExecuteCalls returns the calls made to DeleteKafkaClusterConfigExecute.

func (*ConfigsV3Api) DeleteKafkaTopicConfig 

func (m *ConfigsV3Api) DeleteKafkaTopicConfig(ctx context.Context, clusterId, topicName, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicConfigRequest

DeleteKafkaTopicConfig mocks base method by wrapping the associated func.

func (*ConfigsV3Api) DeleteKafkaTopicConfigCalled 

func (m *ConfigsV3Api) DeleteKafkaTopicConfigCalled() bool

DeleteKafkaTopicConfigCalled returns true if DeleteKafkaTopicConfig was called at least once.

func (*ConfigsV3Api) DeleteKafkaTopicConfigCalls 

func (m *ConfigsV3Api) DeleteKafkaTopicConfigCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
	Name      string
}

DeleteKafkaTopicConfigCalls returns the calls made to DeleteKafkaTopicConfig.

func (*ConfigsV3Api) DeleteKafkaTopicConfigExecute 

func (m *ConfigsV3Api) DeleteKafkaTopicConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicConfigRequest) (*net_http.Response, error)

DeleteKafkaTopicConfigExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) DeleteKafkaTopicConfigExecuteCalled 

func (m *ConfigsV3Api) DeleteKafkaTopicConfigExecuteCalled() bool

DeleteKafkaTopicConfigExecuteCalled returns true if DeleteKafkaTopicConfigExecute was called at least once.

func (*ConfigsV3Api) DeleteKafkaTopicConfigExecuteCalls 

func (m *ConfigsV3Api) DeleteKafkaTopicConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicConfigRequest
}

DeleteKafkaTopicConfigExecuteCalls returns the calls made to DeleteKafkaTopicConfigExecute.

func (*ConfigsV3Api) GetKafkaClusterConfig 

func (m *ConfigsV3Api) GetKafkaClusterConfig(ctx context.Context, clusterId, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterConfigRequest

GetKafkaClusterConfig mocks base method by wrapping the associated func.

func (*ConfigsV3Api) GetKafkaClusterConfigCalled 

func (m *ConfigsV3Api) GetKafkaClusterConfigCalled() bool

GetKafkaClusterConfigCalled returns true if GetKafkaClusterConfig was called at least once.

func (*ConfigsV3Api) GetKafkaClusterConfigCalls 

func (m *ConfigsV3Api) GetKafkaClusterConfigCalls() []struct {
	Ctx       context.Context
	ClusterId string
	Name      string
}

GetKafkaClusterConfigCalls returns the calls made to GetKafkaClusterConfig.

func (*ConfigsV3Api) GetKafkaClusterConfigExecute 

func (m *ConfigsV3Api) GetKafkaClusterConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterConfigRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ClusterConfigData, *net_http.Response, error)

GetKafkaClusterConfigExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) GetKafkaClusterConfigExecuteCalled 

func (m *ConfigsV3Api) GetKafkaClusterConfigExecuteCalled() bool

GetKafkaClusterConfigExecuteCalled returns true if GetKafkaClusterConfigExecute was called at least once.

func (*ConfigsV3Api) GetKafkaClusterConfigExecuteCalls 

func (m *ConfigsV3Api) GetKafkaClusterConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaClusterConfigRequest
}

GetKafkaClusterConfigExecuteCalls returns the calls made to GetKafkaClusterConfigExecute.

func (*ConfigsV3Api) GetKafkaTopicConfig 

func (m *ConfigsV3Api) GetKafkaTopicConfig(ctx context.Context, clusterId, topicName, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicConfigRequest

GetKafkaTopicConfig mocks base method by wrapping the associated func.

func (*ConfigsV3Api) GetKafkaTopicConfigCalled 

func (m *ConfigsV3Api) GetKafkaTopicConfigCalled() bool

GetKafkaTopicConfigCalled returns true if GetKafkaTopicConfig was called at least once.

func (*ConfigsV3Api) GetKafkaTopicConfigCalls 

func (m *ConfigsV3Api) GetKafkaTopicConfigCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
	Name      string
}

GetKafkaTopicConfigCalls returns the calls made to GetKafkaTopicConfig.

func (*ConfigsV3Api) GetKafkaTopicConfigExecute 

func (m *ConfigsV3Api) GetKafkaTopicConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicConfigRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicConfigData, *net_http.Response, error)

GetKafkaTopicConfigExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) GetKafkaTopicConfigExecuteCalled 

func (m *ConfigsV3Api) GetKafkaTopicConfigExecuteCalled() bool

GetKafkaTopicConfigExecuteCalled returns true if GetKafkaTopicConfigExecute was called at least once.

func (*ConfigsV3Api) GetKafkaTopicConfigExecuteCalls 

func (m *ConfigsV3Api) GetKafkaTopicConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicConfigRequest
}

GetKafkaTopicConfigExecuteCalls returns the calls made to GetKafkaTopicConfigExecute.

func (*ConfigsV3Api) ListKafkaAllTopicConfigs 

func (m *ConfigsV3Api) ListKafkaAllTopicConfigs(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaAllTopicConfigsRequest

ListKafkaAllTopicConfigs mocks base method by wrapping the associated func.

func (*ConfigsV3Api) ListKafkaAllTopicConfigsCalled 

func (m *ConfigsV3Api) ListKafkaAllTopicConfigsCalled() bool

ListKafkaAllTopicConfigsCalled returns true if ListKafkaAllTopicConfigs was called at least once.

func (*ConfigsV3Api) ListKafkaAllTopicConfigsCalls 

func (m *ConfigsV3Api) ListKafkaAllTopicConfigsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

ListKafkaAllTopicConfigsCalls returns the calls made to ListKafkaAllTopicConfigs.

func (*ConfigsV3Api) ListKafkaAllTopicConfigsExecute 

func (m *ConfigsV3Api) ListKafkaAllTopicConfigsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaAllTopicConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicConfigDataList, *net_http.Response, error)

ListKafkaAllTopicConfigsExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) ListKafkaAllTopicConfigsExecuteCalled 

func (m *ConfigsV3Api) ListKafkaAllTopicConfigsExecuteCalled() bool

ListKafkaAllTopicConfigsExecuteCalled returns true if ListKafkaAllTopicConfigsExecute was called at least once.

func (*ConfigsV3Api) ListKafkaAllTopicConfigsExecuteCalls 

func (m *ConfigsV3Api) ListKafkaAllTopicConfigsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaAllTopicConfigsRequest
}

ListKafkaAllTopicConfigsExecuteCalls returns the calls made to ListKafkaAllTopicConfigsExecute.

func (*ConfigsV3Api) ListKafkaClusterConfigs 

func (m *ConfigsV3Api) ListKafkaClusterConfigs(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaClusterConfigsRequest

ListKafkaClusterConfigs mocks base method by wrapping the associated func.

func (*ConfigsV3Api) ListKafkaClusterConfigsCalled 

func (m *ConfigsV3Api) ListKafkaClusterConfigsCalled() bool

ListKafkaClusterConfigsCalled returns true if ListKafkaClusterConfigs was called at least once.

func (*ConfigsV3Api) ListKafkaClusterConfigsCalls 

func (m *ConfigsV3Api) ListKafkaClusterConfigsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

ListKafkaClusterConfigsCalls returns the calls made to ListKafkaClusterConfigs.

func (*ConfigsV3Api) ListKafkaClusterConfigsExecute 

func (m *ConfigsV3Api) ListKafkaClusterConfigsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaClusterConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ClusterConfigDataList, *net_http.Response, error)

ListKafkaClusterConfigsExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) ListKafkaClusterConfigsExecuteCalled 

func (m *ConfigsV3Api) ListKafkaClusterConfigsExecuteCalled() bool

ListKafkaClusterConfigsExecuteCalled returns true if ListKafkaClusterConfigsExecute was called at least once.

func (*ConfigsV3Api) ListKafkaClusterConfigsExecuteCalls 

func (m *ConfigsV3Api) ListKafkaClusterConfigsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaClusterConfigsRequest
}

ListKafkaClusterConfigsExecuteCalls returns the calls made to ListKafkaClusterConfigsExecute.

func (*ConfigsV3Api) ListKafkaDefaultTopicConfigs 

func (m *ConfigsV3Api) ListKafkaDefaultTopicConfigs(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaDefaultTopicConfigsRequest

ListKafkaDefaultTopicConfigs mocks base method by wrapping the associated func.

func (*ConfigsV3Api) ListKafkaDefaultTopicConfigsCalled 

func (m *ConfigsV3Api) ListKafkaDefaultTopicConfigsCalled() bool

ListKafkaDefaultTopicConfigsCalled returns true if ListKafkaDefaultTopicConfigs was called at least once.

func (*ConfigsV3Api) ListKafkaDefaultTopicConfigsCalls 

func (m *ConfigsV3Api) ListKafkaDefaultTopicConfigsCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
}

ListKafkaDefaultTopicConfigsCalls returns the calls made to ListKafkaDefaultTopicConfigs.

func (*ConfigsV3Api) ListKafkaDefaultTopicConfigsExecute 

func (m *ConfigsV3Api) ListKafkaDefaultTopicConfigsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaDefaultTopicConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicConfigDataList, *net_http.Response, error)

ListKafkaDefaultTopicConfigsExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) ListKafkaDefaultTopicConfigsExecuteCalled 

func (m *ConfigsV3Api) ListKafkaDefaultTopicConfigsExecuteCalled() bool

ListKafkaDefaultTopicConfigsExecuteCalled returns true if ListKafkaDefaultTopicConfigsExecute was called at least once.

func (*ConfigsV3Api) ListKafkaDefaultTopicConfigsExecuteCalls 

func (m *ConfigsV3Api) ListKafkaDefaultTopicConfigsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaDefaultTopicConfigsRequest
}

ListKafkaDefaultTopicConfigsExecuteCalls returns the calls made to ListKafkaDefaultTopicConfigsExecute.

func (*ConfigsV3Api) ListKafkaTopicConfigs 

func (m *ConfigsV3Api) ListKafkaTopicConfigs(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicConfigsRequest

ListKafkaTopicConfigs mocks base method by wrapping the associated func.

func (*ConfigsV3Api) ListKafkaTopicConfigsCalled 

func (m *ConfigsV3Api) ListKafkaTopicConfigsCalled() bool

ListKafkaTopicConfigsCalled returns true if ListKafkaTopicConfigs was called at least once.

func (*ConfigsV3Api) ListKafkaTopicConfigsCalls 

func (m *ConfigsV3Api) ListKafkaTopicConfigsCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
}

ListKafkaTopicConfigsCalls returns the calls made to ListKafkaTopicConfigs.

func (*ConfigsV3Api) ListKafkaTopicConfigsExecute 

func (m *ConfigsV3Api) ListKafkaTopicConfigsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicConfigsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicConfigDataList, *net_http.Response, error)

ListKafkaTopicConfigsExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) ListKafkaTopicConfigsExecuteCalled 

func (m *ConfigsV3Api) ListKafkaTopicConfigsExecuteCalled() bool

ListKafkaTopicConfigsExecuteCalled returns true if ListKafkaTopicConfigsExecute was called at least once.

func (*ConfigsV3Api) ListKafkaTopicConfigsExecuteCalls 

func (m *ConfigsV3Api) ListKafkaTopicConfigsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicConfigsRequest
}

ListKafkaTopicConfigsExecuteCalls returns the calls made to ListKafkaTopicConfigsExecute.

func (*ConfigsV3Api) Reset 

func (m *ConfigsV3Api) Reset()

Reset resets the calls made to the mocked methods.

func (*ConfigsV3Api) UpdateKafkaClusterConfig 

func (m *ConfigsV3Api) UpdateKafkaClusterConfig(ctx context.Context, clusterId, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigRequest

UpdateKafkaClusterConfig mocks base method by wrapping the associated func.

func (*ConfigsV3Api) UpdateKafkaClusterConfigCalled 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigCalled() bool

UpdateKafkaClusterConfigCalled returns true if UpdateKafkaClusterConfig was called at least once.

func (*ConfigsV3Api) UpdateKafkaClusterConfigCalls 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigCalls() []struct {
	Ctx       context.Context
	ClusterId string
	Name      string
}

UpdateKafkaClusterConfigCalls returns the calls made to UpdateKafkaClusterConfig.

func (*ConfigsV3Api) UpdateKafkaClusterConfigExecute 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigRequest) (*net_http.Response, error)

UpdateKafkaClusterConfigExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) UpdateKafkaClusterConfigExecuteCalled 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigExecuteCalled() bool

UpdateKafkaClusterConfigExecuteCalled returns true if UpdateKafkaClusterConfigExecute was called at least once.

func (*ConfigsV3Api) UpdateKafkaClusterConfigExecuteCalls 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigRequest
}

UpdateKafkaClusterConfigExecuteCalls returns the calls made to UpdateKafkaClusterConfigExecute.

func (*ConfigsV3Api) UpdateKafkaClusterConfigs 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigs(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigsRequest

UpdateKafkaClusterConfigs mocks base method by wrapping the associated func.

func (*ConfigsV3Api) UpdateKafkaClusterConfigsCalled 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigsCalled() bool

UpdateKafkaClusterConfigsCalled returns true if UpdateKafkaClusterConfigs was called at least once.

func (*ConfigsV3Api) UpdateKafkaClusterConfigsCalls 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

UpdateKafkaClusterConfigsCalls returns the calls made to UpdateKafkaClusterConfigs.

func (*ConfigsV3Api) UpdateKafkaClusterConfigsExecute 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigsRequest) (*net_http.Response, error)

UpdateKafkaClusterConfigsExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) UpdateKafkaClusterConfigsExecuteCalled 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigsExecuteCalled() bool

UpdateKafkaClusterConfigsExecuteCalled returns true if UpdateKafkaClusterConfigsExecute was called at least once.

func (*ConfigsV3Api) UpdateKafkaClusterConfigsExecuteCalls 

func (m *ConfigsV3Api) UpdateKafkaClusterConfigsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaClusterConfigsRequest
}

UpdateKafkaClusterConfigsExecuteCalls returns the calls made to UpdateKafkaClusterConfigsExecute.

func (*ConfigsV3Api) UpdateKafkaTopicConfig 

func (m *ConfigsV3Api) UpdateKafkaTopicConfig(ctx context.Context, clusterId, topicName, name string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigRequest

UpdateKafkaTopicConfig mocks base method by wrapping the associated func.

func (*ConfigsV3Api) UpdateKafkaTopicConfigBatch 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigBatch(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigBatchRequest

UpdateKafkaTopicConfigBatch mocks base method by wrapping the associated func.

func (*ConfigsV3Api) UpdateKafkaTopicConfigBatchCalled 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigBatchCalled() bool

UpdateKafkaTopicConfigBatchCalled returns true if UpdateKafkaTopicConfigBatch was called at least once.

func (*ConfigsV3Api) UpdateKafkaTopicConfigBatchCalls 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigBatchCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
}

UpdateKafkaTopicConfigBatchCalls returns the calls made to UpdateKafkaTopicConfigBatch.

func (*ConfigsV3Api) UpdateKafkaTopicConfigBatchExecute 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigBatchExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigBatchRequest) (*net_http.Response, error)

UpdateKafkaTopicConfigBatchExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) UpdateKafkaTopicConfigBatchExecuteCalled 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigBatchExecuteCalled() bool

UpdateKafkaTopicConfigBatchExecuteCalled returns true if UpdateKafkaTopicConfigBatchExecute was called at least once.

func (*ConfigsV3Api) UpdateKafkaTopicConfigBatchExecuteCalls 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigBatchExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigBatchRequest
}

UpdateKafkaTopicConfigBatchExecuteCalls returns the calls made to UpdateKafkaTopicConfigBatchExecute.

func (*ConfigsV3Api) UpdateKafkaTopicConfigCalled 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigCalled() bool

UpdateKafkaTopicConfigCalled returns true if UpdateKafkaTopicConfig was called at least once.

func (*ConfigsV3Api) UpdateKafkaTopicConfigCalls 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
	Name      string
}

UpdateKafkaTopicConfigCalls returns the calls made to UpdateKafkaTopicConfig.

func (*ConfigsV3Api) UpdateKafkaTopicConfigExecute 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigRequest) (*net_http.Response, error)

UpdateKafkaTopicConfigExecute mocks base method by wrapping the associated func.

func (*ConfigsV3Api) UpdateKafkaTopicConfigExecuteCalled 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigExecuteCalled() bool

UpdateKafkaTopicConfigExecuteCalled returns true if UpdateKafkaTopicConfigExecute was called at least once.

func (*ConfigsV3Api) UpdateKafkaTopicConfigExecuteCalls 

func (m *ConfigsV3Api) UpdateKafkaTopicConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdateKafkaTopicConfigRequest
}

UpdateKafkaTopicConfigExecuteCalls returns the calls made to UpdateKafkaTopicConfigExecute.

type ConsumerGroupV3Api 

type ConsumerGroupV3Api struct {
	GetKafkaConsumerFunc func(ctx context.Context, clusterId, consumerGroupId, consumerId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerRequest

	GetKafkaConsumerExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerData, *net_http.Response, error)

	GetKafkaConsumerGroupFunc func(ctx context.Context, clusterId, consumerGroupId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupRequest

	GetKafkaConsumerGroupExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerGroupData, *net_http.Response, error)

	GetKafkaConsumerGroupLagSummaryFunc func(ctx context.Context, clusterId, consumerGroupId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupLagSummaryRequest

	GetKafkaConsumerGroupLagSummaryExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupLagSummaryRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerGroupLagSummaryData, *net_http.Response, error)

	GetKafkaConsumerLagFunc func(ctx context.Context, clusterId, consumerGroupId, topicName string, partitionId int32) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerLagRequest

	GetKafkaConsumerLagExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerLagRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerLagData, *net_http.Response, error)

	ListKafkaConsumerGroupsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerGroupsRequest

	ListKafkaConsumerGroupsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerGroupsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerGroupDataList, *net_http.Response, error)

	ListKafkaConsumerLagsFunc func(ctx context.Context, clusterId, consumerGroupId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerLagsRequest

	ListKafkaConsumerLagsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerLagsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerLagDataList, *net_http.Response, error)

	ListKafkaConsumersFunc func(ctx context.Context, clusterId, consumerGroupId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumersRequest

	ListKafkaConsumersExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumersRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerDataList, *net_http.Response, error)
	// contains filtered or unexported fields
}

ConsumerGroupV3Api is a mock of ConsumerGroupV3Api interface

func (*ConsumerGroupV3Api) GetKafkaConsumer 

func (m *ConsumerGroupV3Api) GetKafkaConsumer(ctx context.Context, clusterId, consumerGroupId, consumerId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerRequest

GetKafkaConsumer mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) GetKafkaConsumerCalled 

func (m *ConsumerGroupV3Api) GetKafkaConsumerCalled() bool

GetKafkaConsumerCalled returns true if GetKafkaConsumer was called at least once.

func (*ConsumerGroupV3Api) GetKafkaConsumerCalls 

func (m *ConsumerGroupV3Api) GetKafkaConsumerCalls() []struct {
	Ctx             context.Context
	ClusterId       string
	ConsumerGroupId string
	ConsumerId      string
}

GetKafkaConsumerCalls returns the calls made to GetKafkaConsumer.

func (*ConsumerGroupV3Api) GetKafkaConsumerExecute 

func (m *ConsumerGroupV3Api) GetKafkaConsumerExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerData, *net_http.Response, error)

GetKafkaConsumerExecute mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) GetKafkaConsumerExecuteCalled 

func (m *ConsumerGroupV3Api) GetKafkaConsumerExecuteCalled() bool

GetKafkaConsumerExecuteCalled returns true if GetKafkaConsumerExecute was called at least once.

func (*ConsumerGroupV3Api) GetKafkaConsumerExecuteCalls 

func (m *ConsumerGroupV3Api) GetKafkaConsumerExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerRequest
}

GetKafkaConsumerExecuteCalls returns the calls made to GetKafkaConsumerExecute.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroup 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroup(ctx context.Context, clusterId, consumerGroupId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupRequest

GetKafkaConsumerGroup mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupCalled 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupCalled() bool

GetKafkaConsumerGroupCalled returns true if GetKafkaConsumerGroup was called at least once.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupCalls 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupCalls() []struct {
	Ctx             context.Context
	ClusterId       string
	ConsumerGroupId string
}

GetKafkaConsumerGroupCalls returns the calls made to GetKafkaConsumerGroup.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupExecute 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerGroupData, *net_http.Response, error)

GetKafkaConsumerGroupExecute mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupExecuteCalled 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupExecuteCalled() bool

GetKafkaConsumerGroupExecuteCalled returns true if GetKafkaConsumerGroupExecute was called at least once.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupExecuteCalls 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupRequest
}

GetKafkaConsumerGroupExecuteCalls returns the calls made to GetKafkaConsumerGroupExecute.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummary 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummary(ctx context.Context, clusterId, consumerGroupId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupLagSummaryRequest

GetKafkaConsumerGroupLagSummary mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryCalled 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryCalled() bool

GetKafkaConsumerGroupLagSummaryCalled returns true if GetKafkaConsumerGroupLagSummary was called at least once.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryCalls 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryCalls() []struct {
	Ctx             context.Context
	ClusterId       string
	ConsumerGroupId string
}

GetKafkaConsumerGroupLagSummaryCalls returns the calls made to GetKafkaConsumerGroupLagSummary.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryExecute 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupLagSummaryRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerGroupLagSummaryData, *net_http.Response, error)

GetKafkaConsumerGroupLagSummaryExecute mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryExecuteCalled 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryExecuteCalled() bool

GetKafkaConsumerGroupLagSummaryExecuteCalled returns true if GetKafkaConsumerGroupLagSummaryExecute was called at least once.

func (*ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryExecuteCalls 

func (m *ConsumerGroupV3Api) GetKafkaConsumerGroupLagSummaryExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerGroupLagSummaryRequest
}

GetKafkaConsumerGroupLagSummaryExecuteCalls returns the calls made to GetKafkaConsumerGroupLagSummaryExecute.

func (*ConsumerGroupV3Api) GetKafkaConsumerLag added in v0.14.0 

func (m *ConsumerGroupV3Api) GetKafkaConsumerLag(ctx context.Context, clusterId, consumerGroupId, topicName string, partitionId int32) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerLagRequest

GetKafkaConsumerLag mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) GetKafkaConsumerLagCalled added in v0.14.0 

func (m *ConsumerGroupV3Api) GetKafkaConsumerLagCalled() bool

GetKafkaConsumerLagCalled returns true if GetKafkaConsumerLag was called at least once.

func (*ConsumerGroupV3Api) GetKafkaConsumerLagCalls added in v0.14.0 

func (m *ConsumerGroupV3Api) GetKafkaConsumerLagCalls() []struct {
	Ctx             context.Context
	ClusterId       string
	ConsumerGroupId string
	TopicName       string
	PartitionId     int32
}

GetKafkaConsumerLagCalls returns the calls made to GetKafkaConsumerLag.

func (*ConsumerGroupV3Api) GetKafkaConsumerLagExecute added in v0.14.0 

func (m *ConsumerGroupV3Api) GetKafkaConsumerLagExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerLagRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerLagData, *net_http.Response, error)

GetKafkaConsumerLagExecute mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) GetKafkaConsumerLagExecuteCalled added in v0.14.0 

func (m *ConsumerGroupV3Api) GetKafkaConsumerLagExecuteCalled() bool

GetKafkaConsumerLagExecuteCalled returns true if GetKafkaConsumerLagExecute was called at least once.

func (*ConsumerGroupV3Api) GetKafkaConsumerLagExecuteCalls added in v0.14.0 

func (m *ConsumerGroupV3Api) GetKafkaConsumerLagExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaConsumerLagRequest
}

GetKafkaConsumerLagExecuteCalls returns the calls made to GetKafkaConsumerLagExecute.

func (*ConsumerGroupV3Api) ListKafkaConsumerGroups 

func (m *ConsumerGroupV3Api) ListKafkaConsumerGroups(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerGroupsRequest

ListKafkaConsumerGroups mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) ListKafkaConsumerGroupsCalled 

func (m *ConsumerGroupV3Api) ListKafkaConsumerGroupsCalled() bool

ListKafkaConsumerGroupsCalled returns true if ListKafkaConsumerGroups was called at least once.

func (*ConsumerGroupV3Api) ListKafkaConsumerGroupsCalls 

func (m *ConsumerGroupV3Api) ListKafkaConsumerGroupsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

ListKafkaConsumerGroupsCalls returns the calls made to ListKafkaConsumerGroups.

func (*ConsumerGroupV3Api) ListKafkaConsumerGroupsExecute 

func (m *ConsumerGroupV3Api) ListKafkaConsumerGroupsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerGroupsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerGroupDataList, *net_http.Response, error)

ListKafkaConsumerGroupsExecute mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) ListKafkaConsumerGroupsExecuteCalled 

func (m *ConsumerGroupV3Api) ListKafkaConsumerGroupsExecuteCalled() bool

ListKafkaConsumerGroupsExecuteCalled returns true if ListKafkaConsumerGroupsExecute was called at least once.

func (*ConsumerGroupV3Api) ListKafkaConsumerGroupsExecuteCalls 

func (m *ConsumerGroupV3Api) ListKafkaConsumerGroupsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerGroupsRequest
}

ListKafkaConsumerGroupsExecuteCalls returns the calls made to ListKafkaConsumerGroupsExecute.

func (*ConsumerGroupV3Api) ListKafkaConsumerLags 

func (m *ConsumerGroupV3Api) ListKafkaConsumerLags(ctx context.Context, clusterId, consumerGroupId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerLagsRequest

ListKafkaConsumerLags mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) ListKafkaConsumerLagsCalled 

func (m *ConsumerGroupV3Api) ListKafkaConsumerLagsCalled() bool

ListKafkaConsumerLagsCalled returns true if ListKafkaConsumerLags was called at least once.

func (*ConsumerGroupV3Api) ListKafkaConsumerLagsCalls 

func (m *ConsumerGroupV3Api) ListKafkaConsumerLagsCalls() []struct {
	Ctx             context.Context
	ClusterId       string
	ConsumerGroupId string
}

ListKafkaConsumerLagsCalls returns the calls made to ListKafkaConsumerLags.

func (*ConsumerGroupV3Api) ListKafkaConsumerLagsExecute 

func (m *ConsumerGroupV3Api) ListKafkaConsumerLagsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerLagsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerLagDataList, *net_http.Response, error)

ListKafkaConsumerLagsExecute mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) ListKafkaConsumerLagsExecuteCalled 

func (m *ConsumerGroupV3Api) ListKafkaConsumerLagsExecuteCalled() bool

ListKafkaConsumerLagsExecuteCalled returns true if ListKafkaConsumerLagsExecute was called at least once.

func (*ConsumerGroupV3Api) ListKafkaConsumerLagsExecuteCalls 

func (m *ConsumerGroupV3Api) ListKafkaConsumerLagsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumerLagsRequest
}

ListKafkaConsumerLagsExecuteCalls returns the calls made to ListKafkaConsumerLagsExecute.

func (*ConsumerGroupV3Api) ListKafkaConsumers 

func (m *ConsumerGroupV3Api) ListKafkaConsumers(ctx context.Context, clusterId, consumerGroupId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumersRequest

ListKafkaConsumers mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) ListKafkaConsumersCalled 

func (m *ConsumerGroupV3Api) ListKafkaConsumersCalled() bool

ListKafkaConsumersCalled returns true if ListKafkaConsumers was called at least once.

func (*ConsumerGroupV3Api) ListKafkaConsumersCalls 

func (m *ConsumerGroupV3Api) ListKafkaConsumersCalls() []struct {
	Ctx             context.Context
	ClusterId       string
	ConsumerGroupId string
}

ListKafkaConsumersCalls returns the calls made to ListKafkaConsumers.

func (*ConsumerGroupV3Api) ListKafkaConsumersExecute 

func (m *ConsumerGroupV3Api) ListKafkaConsumersExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumersRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ConsumerDataList, *net_http.Response, error)

ListKafkaConsumersExecute mocks base method by wrapping the associated func.

func (*ConsumerGroupV3Api) ListKafkaConsumersExecuteCalled 

func (m *ConsumerGroupV3Api) ListKafkaConsumersExecuteCalled() bool

ListKafkaConsumersExecuteCalled returns true if ListKafkaConsumersExecute was called at least once.

func (*ConsumerGroupV3Api) ListKafkaConsumersExecuteCalls 

func (m *ConsumerGroupV3Api) ListKafkaConsumersExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaConsumersRequest
}

ListKafkaConsumersExecuteCalls returns the calls made to ListKafkaConsumersExecute.

func (*ConsumerGroupV3Api) Reset 

func (m *ConsumerGroupV3Api) Reset()

Reset resets the calls made to the mocked methods.

type PartitionV3Api 

type PartitionV3Api struct {
	GetKafkaPartitionFunc func(ctx context.Context, clusterId, topicName string, partitionId int32) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaPartitionRequest

	GetKafkaPartitionExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaPartitionRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.PartitionData, *net_http.Response, error)

	ListKafkaPartitionsFunc func(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaPartitionsRequest

	ListKafkaPartitionsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaPartitionsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.PartitionDataList, *net_http.Response, error)
	// contains filtered or unexported fields
}

PartitionV3Api is a mock of PartitionV3Api interface

func (*PartitionV3Api) GetKafkaPartition 

func (m *PartitionV3Api) GetKafkaPartition(ctx context.Context, clusterId, topicName string, partitionId int32) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaPartitionRequest

GetKafkaPartition mocks base method by wrapping the associated func.

func (*PartitionV3Api) GetKafkaPartitionCalled 

func (m *PartitionV3Api) GetKafkaPartitionCalled() bool

GetKafkaPartitionCalled returns true if GetKafkaPartition was called at least once.

func (*PartitionV3Api) GetKafkaPartitionCalls 

func (m *PartitionV3Api) GetKafkaPartitionCalls() []struct {
	Ctx         context.Context
	ClusterId   string
	TopicName   string
	PartitionId int32
}

GetKafkaPartitionCalls returns the calls made to GetKafkaPartition.

func (*PartitionV3Api) GetKafkaPartitionExecute 

func (m *PartitionV3Api) GetKafkaPartitionExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaPartitionRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.PartitionData, *net_http.Response, error)

GetKafkaPartitionExecute mocks base method by wrapping the associated func.

func (*PartitionV3Api) GetKafkaPartitionExecuteCalled 

func (m *PartitionV3Api) GetKafkaPartitionExecuteCalled() bool

GetKafkaPartitionExecuteCalled returns true if GetKafkaPartitionExecute was called at least once.

func (*PartitionV3Api) GetKafkaPartitionExecuteCalls 

func (m *PartitionV3Api) GetKafkaPartitionExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaPartitionRequest
}

GetKafkaPartitionExecuteCalls returns the calls made to GetKafkaPartitionExecute.

func (*PartitionV3Api) ListKafkaPartitions 

func (m *PartitionV3Api) ListKafkaPartitions(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaPartitionsRequest

ListKafkaPartitions mocks base method by wrapping the associated func.

func (*PartitionV3Api) ListKafkaPartitionsCalled 

func (m *PartitionV3Api) ListKafkaPartitionsCalled() bool

ListKafkaPartitionsCalled returns true if ListKafkaPartitions was called at least once.

func (*PartitionV3Api) ListKafkaPartitionsCalls 

func (m *PartitionV3Api) ListKafkaPartitionsCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
}

ListKafkaPartitionsCalls returns the calls made to ListKafkaPartitions.

func (*PartitionV3Api) ListKafkaPartitionsExecute 

func (m *PartitionV3Api) ListKafkaPartitionsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaPartitionsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.PartitionDataList, *net_http.Response, error)

ListKafkaPartitionsExecute mocks base method by wrapping the associated func.

func (*PartitionV3Api) ListKafkaPartitionsExecuteCalled 

func (m *PartitionV3Api) ListKafkaPartitionsExecuteCalled() bool

ListKafkaPartitionsExecuteCalled returns true if ListKafkaPartitionsExecute was called at least once.

func (*PartitionV3Api) ListKafkaPartitionsExecuteCalls 

func (m *PartitionV3Api) ListKafkaPartitionsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaPartitionsRequest
}

ListKafkaPartitionsExecuteCalls returns the calls made to ListKafkaPartitionsExecute.

func (*PartitionV3Api) Reset 

func (m *PartitionV3Api) Reset()

Reset resets the calls made to the mocked methods.

type RecordsV3Api 

type RecordsV3Api struct {
	ProduceRecordFunc func(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiProduceRecordRequest

	ProduceRecordExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiProduceRecordRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ProduceResponse, *net_http.Response, error)
	// contains filtered or unexported fields
}

RecordsV3Api is a mock of RecordsV3Api interface

func (*RecordsV3Api) ProduceRecord added in v0.14.0 

func (m *RecordsV3Api) ProduceRecord(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiProduceRecordRequest

ProduceRecord mocks base method by wrapping the associated func.

func (*RecordsV3Api) ProduceRecordCalled added in v0.14.0 

func (m *RecordsV3Api) ProduceRecordCalled() bool

ProduceRecordCalled returns true if ProduceRecord was called at least once.

func (*RecordsV3Api) ProduceRecordCalls added in v0.14.0 

func (m *RecordsV3Api) ProduceRecordCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
}

ProduceRecordCalls returns the calls made to ProduceRecord.

func (*RecordsV3Api) ProduceRecordExecute added in v0.14.0 

func (m *RecordsV3Api) ProduceRecordExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiProduceRecordRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ProduceResponse, *net_http.Response, error)

ProduceRecordExecute mocks base method by wrapping the associated func.

func (*RecordsV3Api) ProduceRecordExecuteCalled added in v0.14.0 

func (m *RecordsV3Api) ProduceRecordExecuteCalled() bool

ProduceRecordExecuteCalled returns true if ProduceRecordExecute was called at least once.

func (*RecordsV3Api) ProduceRecordExecuteCalls added in v0.14.0 

func (m *RecordsV3Api) ProduceRecordExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiProduceRecordRequest
}

ProduceRecordExecuteCalls returns the calls made to ProduceRecordExecute.

func (*RecordsV3Api) Reset 

func (m *RecordsV3Api) Reset()

Reset resets the calls made to the mocked methods.

type TopicV3Api 

type TopicV3Api struct {
	CreateKafkaTopicFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaTopicRequest

	CreateKafkaTopicExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaTopicRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicData, *net_http.Response, error)

	DeleteKafkaTopicFunc func(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicRequest

	DeleteKafkaTopicExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicRequest) (*net_http.Response, error)

	GetKafkaTopicFunc func(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicRequest

	GetKafkaTopicExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicData, *net_http.Response, error)

	ListKafkaTopicsFunc func(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicsRequest

	ListKafkaTopicsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicDataList, *net_http.Response, error)

	UpdatePartitionCountKafkaTopicFunc func(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdatePartitionCountKafkaTopicRequest

	UpdatePartitionCountKafkaTopicExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdatePartitionCountKafkaTopicRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicData, *net_http.Response, error)
	// contains filtered or unexported fields
}

TopicV3Api is a mock of TopicV3Api interface

func (*TopicV3Api) CreateKafkaTopic 

func (m *TopicV3Api) CreateKafkaTopic(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaTopicRequest

CreateKafkaTopic mocks base method by wrapping the associated func.

func (*TopicV3Api) CreateKafkaTopicCalled 

func (m *TopicV3Api) CreateKafkaTopicCalled() bool

CreateKafkaTopicCalled returns true if CreateKafkaTopic was called at least once.

func (*TopicV3Api) CreateKafkaTopicCalls 

func (m *TopicV3Api) CreateKafkaTopicCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

CreateKafkaTopicCalls returns the calls made to CreateKafkaTopic.

func (*TopicV3Api) CreateKafkaTopicExecute 

func (m *TopicV3Api) CreateKafkaTopicExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaTopicRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicData, *net_http.Response, error)

CreateKafkaTopicExecute mocks base method by wrapping the associated func.

func (*TopicV3Api) CreateKafkaTopicExecuteCalled 

func (m *TopicV3Api) CreateKafkaTopicExecuteCalled() bool

CreateKafkaTopicExecuteCalled returns true if CreateKafkaTopicExecute was called at least once.

func (*TopicV3Api) CreateKafkaTopicExecuteCalls 

func (m *TopicV3Api) CreateKafkaTopicExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiCreateKafkaTopicRequest
}

CreateKafkaTopicExecuteCalls returns the calls made to CreateKafkaTopicExecute.

func (*TopicV3Api) DeleteKafkaTopic 

func (m *TopicV3Api) DeleteKafkaTopic(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicRequest

DeleteKafkaTopic mocks base method by wrapping the associated func.

func (*TopicV3Api) DeleteKafkaTopicCalled 

func (m *TopicV3Api) DeleteKafkaTopicCalled() bool

DeleteKafkaTopicCalled returns true if DeleteKafkaTopic was called at least once.

func (*TopicV3Api) DeleteKafkaTopicCalls 

func (m *TopicV3Api) DeleteKafkaTopicCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
}

DeleteKafkaTopicCalls returns the calls made to DeleteKafkaTopic.

func (*TopicV3Api) DeleteKafkaTopicExecute 

func (m *TopicV3Api) DeleteKafkaTopicExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicRequest) (*net_http.Response, error)

DeleteKafkaTopicExecute mocks base method by wrapping the associated func.

func (*TopicV3Api) DeleteKafkaTopicExecuteCalled 

func (m *TopicV3Api) DeleteKafkaTopicExecuteCalled() bool

DeleteKafkaTopicExecuteCalled returns true if DeleteKafkaTopicExecute was called at least once.

func (*TopicV3Api) DeleteKafkaTopicExecuteCalls 

func (m *TopicV3Api) DeleteKafkaTopicExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiDeleteKafkaTopicRequest
}

DeleteKafkaTopicExecuteCalls returns the calls made to DeleteKafkaTopicExecute.

func (*TopicV3Api) GetKafkaTopic 

func (m *TopicV3Api) GetKafkaTopic(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicRequest

GetKafkaTopic mocks base method by wrapping the associated func.

func (*TopicV3Api) GetKafkaTopicCalled 

func (m *TopicV3Api) GetKafkaTopicCalled() bool

GetKafkaTopicCalled returns true if GetKafkaTopic was called at least once.

func (*TopicV3Api) GetKafkaTopicCalls 

func (m *TopicV3Api) GetKafkaTopicCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
}

GetKafkaTopicCalls returns the calls made to GetKafkaTopic.

func (*TopicV3Api) GetKafkaTopicExecute 

func (m *TopicV3Api) GetKafkaTopicExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicData, *net_http.Response, error)

GetKafkaTopicExecute mocks base method by wrapping the associated func.

func (*TopicV3Api) GetKafkaTopicExecuteCalled 

func (m *TopicV3Api) GetKafkaTopicExecuteCalled() bool

GetKafkaTopicExecuteCalled returns true if GetKafkaTopicExecute was called at least once.

func (*TopicV3Api) GetKafkaTopicExecuteCalls 

func (m *TopicV3Api) GetKafkaTopicExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiGetKafkaTopicRequest
}

GetKafkaTopicExecuteCalls returns the calls made to GetKafkaTopicExecute.

func (*TopicV3Api) ListKafkaTopics 

func (m *TopicV3Api) ListKafkaTopics(ctx context.Context, clusterId string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicsRequest

ListKafkaTopics mocks base method by wrapping the associated func.

func (*TopicV3Api) ListKafkaTopicsCalled 

func (m *TopicV3Api) ListKafkaTopicsCalled() bool

ListKafkaTopicsCalled returns true if ListKafkaTopics was called at least once.

func (*TopicV3Api) ListKafkaTopicsCalls 

func (m *TopicV3Api) ListKafkaTopicsCalls() []struct {
	Ctx       context.Context
	ClusterId string
}

ListKafkaTopicsCalls returns the calls made to ListKafkaTopics.

func (*TopicV3Api) ListKafkaTopicsExecute 

func (m *TopicV3Api) ListKafkaTopicsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicDataList, *net_http.Response, error)

ListKafkaTopicsExecute mocks base method by wrapping the associated func.

func (*TopicV3Api) ListKafkaTopicsExecuteCalled 

func (m *TopicV3Api) ListKafkaTopicsExecuteCalled() bool

ListKafkaTopicsExecuteCalled returns true if ListKafkaTopicsExecute was called at least once.

func (*TopicV3Api) ListKafkaTopicsExecuteCalls 

func (m *TopicV3Api) ListKafkaTopicsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiListKafkaTopicsRequest
}

ListKafkaTopicsExecuteCalls returns the calls made to ListKafkaTopicsExecute.

func (*TopicV3Api) Reset 

func (m *TopicV3Api) Reset()

Reset resets the calls made to the mocked methods.

func (*TopicV3Api) UpdatePartitionCountKafkaTopic added in v0.14.0 

func (m *TopicV3Api) UpdatePartitionCountKafkaTopic(ctx context.Context, clusterId, topicName string) github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdatePartitionCountKafkaTopicRequest

UpdatePartitionCountKafkaTopic mocks base method by wrapping the associated func.

func (*TopicV3Api) UpdatePartitionCountKafkaTopicCalled added in v0.14.0 

func (m *TopicV3Api) UpdatePartitionCountKafkaTopicCalled() bool

UpdatePartitionCountKafkaTopicCalled returns true if UpdatePartitionCountKafkaTopic was called at least once.

func (*TopicV3Api) UpdatePartitionCountKafkaTopicCalls added in v0.14.0 

func (m *TopicV3Api) UpdatePartitionCountKafkaTopicCalls() []struct {
	Ctx       context.Context
	ClusterId string
	TopicName string
}

UpdatePartitionCountKafkaTopicCalls returns the calls made to UpdatePartitionCountKafkaTopic.

func (*TopicV3Api) UpdatePartitionCountKafkaTopicExecute added in v0.14.0 

func (m *TopicV3Api) UpdatePartitionCountKafkaTopicExecute(r github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdatePartitionCountKafkaTopicRequest) (github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.TopicData, *net_http.Response, error)

UpdatePartitionCountKafkaTopicExecute mocks base method by wrapping the associated func.

func (*TopicV3Api) UpdatePartitionCountKafkaTopicExecuteCalled added in v0.14.0 

func (m *TopicV3Api) UpdatePartitionCountKafkaTopicExecuteCalled() bool

UpdatePartitionCountKafkaTopicExecuteCalled returns true if UpdatePartitionCountKafkaTopicExecute was called at least once.

func (*TopicV3Api) UpdatePartitionCountKafkaTopicExecuteCalls added in v0.14.0 

func (m *TopicV3Api) UpdatePartitionCountKafkaTopicExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_kafkarest_v3.ApiUpdatePartitionCountKafkaTopicRequest
}

UpdatePartitionCountKafkaTopicExecuteCalls returns the calls made to UpdatePartitionCountKafkaTopicExecute.

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.