mock

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: May 8, 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 ConnectorsConnectV1Api added in v0.5.0 

type ConnectorsConnectV1Api struct {
	CreateConnectv1ConnectorFunc func(ctx context.Context, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateConnectv1ConnectorRequest

	CreateConnectv1ConnectorExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateConnectv1ConnectorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1ConnectorWithOffsets, *net_http.Response, error)

	CreateOrUpdateConnectv1ConnectorConfigFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateOrUpdateConnectv1ConnectorConfigRequest

	CreateOrUpdateConnectv1ConnectorConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateOrUpdateConnectv1ConnectorConfigRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1Connector, *net_http.Response, error)

	DeleteConnectv1ConnectorFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiDeleteConnectv1ConnectorRequest

	DeleteConnectv1ConnectorExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiDeleteConnectv1ConnectorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.InlineResponse200, *net_http.Response, error)

	GetConnectv1ConnectorConfigFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorConfigRequest

	GetConnectv1ConnectorConfigExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorConfigRequest) (map[string]string, *net_http.Response, error)

	ListConnectv1ConnectorsFunc func(ctx context.Context, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsRequest

	ListConnectv1ConnectorsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsRequest) ([]string, *net_http.Response, error)

	ListConnectv1ConnectorsWithExpansionsFunc func(ctx context.Context, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsWithExpansionsRequest

	ListConnectv1ConnectorsWithExpansionsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsWithExpansionsRequest) (map[string]github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1ConnectorExpansion, *net_http.Response, error)

	ReadConnectv1ConnectorFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorRequest

	ReadConnectv1ConnectorExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1Connector, *net_http.Response, error)
	// contains filtered or unexported fields
}

ConnectorsConnectV1Api is a mock of ConnectorsConnectV1Api interface

func (*ConnectorsConnectV1Api) CreateConnectv1Connector added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateConnectv1Connector(ctx context.Context, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateConnectv1ConnectorRequest

CreateConnectv1Connector mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) CreateConnectv1ConnectorCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateConnectv1ConnectorCalled() bool

CreateConnectv1ConnectorCalled returns true if CreateConnectv1Connector was called at least once.

func (*ConnectorsConnectV1Api) CreateConnectv1ConnectorCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateConnectv1ConnectorCalls() []struct {
	Ctx            context.Context
	EnvironmentId  string
	KafkaClusterId string
}

CreateConnectv1ConnectorCalls returns the calls made to CreateConnectv1Connector.

func (*ConnectorsConnectV1Api) CreateConnectv1ConnectorExecute added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateConnectv1ConnectorExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateConnectv1ConnectorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1ConnectorWithOffsets, *net_http.Response, error)

CreateConnectv1ConnectorExecute mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) CreateConnectv1ConnectorExecuteCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateConnectv1ConnectorExecuteCalled() bool

CreateConnectv1ConnectorExecuteCalled returns true if CreateConnectv1ConnectorExecute was called at least once.

func (*ConnectorsConnectV1Api) CreateConnectv1ConnectorExecuteCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateConnectv1ConnectorExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateConnectv1ConnectorRequest
}

CreateConnectv1ConnectorExecuteCalls returns the calls made to CreateConnectv1ConnectorExecute.

func (*ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfig added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfig(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateOrUpdateConnectv1ConnectorConfigRequest

CreateOrUpdateConnectv1ConnectorConfig mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigCalled() bool

CreateOrUpdateConnectv1ConnectorConfigCalled returns true if CreateOrUpdateConnectv1ConnectorConfig was called at least once.

func (*ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

CreateOrUpdateConnectv1ConnectorConfigCalls returns the calls made to CreateOrUpdateConnectv1ConnectorConfig.

func (*ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigExecute added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateOrUpdateConnectv1ConnectorConfigRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1Connector, *net_http.Response, error)

CreateOrUpdateConnectv1ConnectorConfigExecute mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigExecuteCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigExecuteCalled() bool

CreateOrUpdateConnectv1ConnectorConfigExecuteCalled returns true if CreateOrUpdateConnectv1ConnectorConfigExecute was called at least once.

func (*ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigExecuteCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) CreateOrUpdateConnectv1ConnectorConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiCreateOrUpdateConnectv1ConnectorConfigRequest
}

CreateOrUpdateConnectv1ConnectorConfigExecuteCalls returns the calls made to CreateOrUpdateConnectv1ConnectorConfigExecute.

func (*ConnectorsConnectV1Api) DeleteConnectv1Connector added in v0.5.0 

func (m *ConnectorsConnectV1Api) DeleteConnectv1Connector(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiDeleteConnectv1ConnectorRequest

DeleteConnectv1Connector mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) DeleteConnectv1ConnectorCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) DeleteConnectv1ConnectorCalled() bool

DeleteConnectv1ConnectorCalled returns true if DeleteConnectv1Connector was called at least once.

func (*ConnectorsConnectV1Api) DeleteConnectv1ConnectorCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) DeleteConnectv1ConnectorCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

DeleteConnectv1ConnectorCalls returns the calls made to DeleteConnectv1Connector.

func (*ConnectorsConnectV1Api) DeleteConnectv1ConnectorExecute added in v0.5.0 

func (m *ConnectorsConnectV1Api) DeleteConnectv1ConnectorExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiDeleteConnectv1ConnectorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.InlineResponse200, *net_http.Response, error)

DeleteConnectv1ConnectorExecute mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) DeleteConnectv1ConnectorExecuteCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) DeleteConnectv1ConnectorExecuteCalled() bool

DeleteConnectv1ConnectorExecuteCalled returns true if DeleteConnectv1ConnectorExecute was called at least once.

func (*ConnectorsConnectV1Api) DeleteConnectv1ConnectorExecuteCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) DeleteConnectv1ConnectorExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiDeleteConnectv1ConnectorRequest
}

DeleteConnectv1ConnectorExecuteCalls returns the calls made to DeleteConnectv1ConnectorExecute.

func (*ConnectorsConnectV1Api) GetConnectv1ConnectorConfig added in v0.5.0 

func (m *ConnectorsConnectV1Api) GetConnectv1ConnectorConfig(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorConfigRequest

GetConnectv1ConnectorConfig mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) GetConnectv1ConnectorConfigCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) GetConnectv1ConnectorConfigCalled() bool

GetConnectv1ConnectorConfigCalled returns true if GetConnectv1ConnectorConfig was called at least once.

func (*ConnectorsConnectV1Api) GetConnectv1ConnectorConfigCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) GetConnectv1ConnectorConfigCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

GetConnectv1ConnectorConfigCalls returns the calls made to GetConnectv1ConnectorConfig.

func (*ConnectorsConnectV1Api) GetConnectv1ConnectorConfigExecute added in v0.5.0 

func (m *ConnectorsConnectV1Api) GetConnectv1ConnectorConfigExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorConfigRequest) (map[string]string, *net_http.Response, error)

GetConnectv1ConnectorConfigExecute mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) GetConnectv1ConnectorConfigExecuteCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) GetConnectv1ConnectorConfigExecuteCalled() bool

GetConnectv1ConnectorConfigExecuteCalled returns true if GetConnectv1ConnectorConfigExecute was called at least once.

func (*ConnectorsConnectV1Api) GetConnectv1ConnectorConfigExecuteCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) GetConnectv1ConnectorConfigExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorConfigRequest
}

GetConnectv1ConnectorConfigExecuteCalls returns the calls made to GetConnectv1ConnectorConfigExecute.

func (*ConnectorsConnectV1Api) ListConnectv1Connectors added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1Connectors(ctx context.Context, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsRequest

ListConnectv1Connectors mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsCalled() bool

ListConnectv1ConnectorsCalled returns true if ListConnectv1Connectors was called at least once.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsCalls() []struct {
	Ctx            context.Context
	EnvironmentId  string
	KafkaClusterId string
}

ListConnectv1ConnectorsCalls returns the calls made to ListConnectv1Connectors.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsExecute added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsRequest) ([]string, *net_http.Response, error)

ListConnectv1ConnectorsExecute mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsExecuteCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsExecuteCalled() bool

ListConnectv1ConnectorsExecuteCalled returns true if ListConnectv1ConnectorsExecute was called at least once.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsExecuteCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsRequest
}

ListConnectv1ConnectorsExecuteCalls returns the calls made to ListConnectv1ConnectorsExecute.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansions added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansions(ctx context.Context, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsWithExpansionsRequest

ListConnectv1ConnectorsWithExpansions mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsCalled() bool

ListConnectv1ConnectorsWithExpansionsCalled returns true if ListConnectv1ConnectorsWithExpansions was called at least once.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsCalls() []struct {
	Ctx            context.Context
	EnvironmentId  string
	KafkaClusterId string
}

ListConnectv1ConnectorsWithExpansionsCalls returns the calls made to ListConnectv1ConnectorsWithExpansions.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsExecute added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsWithExpansionsRequest) (map[string]github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1ConnectorExpansion, *net_http.Response, error)

ListConnectv1ConnectorsWithExpansionsExecute mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsExecuteCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsExecuteCalled() bool

ListConnectv1ConnectorsWithExpansionsExecuteCalled returns true if ListConnectv1ConnectorsWithExpansionsExecute was called at least once.

func (*ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsExecuteCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) ListConnectv1ConnectorsWithExpansionsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorsWithExpansionsRequest
}

ListConnectv1ConnectorsWithExpansionsExecuteCalls returns the calls made to ListConnectv1ConnectorsWithExpansionsExecute.

func (*ConnectorsConnectV1Api) ReadConnectv1Connector added in v0.5.0 

func (m *ConnectorsConnectV1Api) ReadConnectv1Connector(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorRequest

ReadConnectv1Connector mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) ReadConnectv1ConnectorCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) ReadConnectv1ConnectorCalled() bool

ReadConnectv1ConnectorCalled returns true if ReadConnectv1Connector was called at least once.

func (*ConnectorsConnectV1Api) ReadConnectv1ConnectorCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) ReadConnectv1ConnectorCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

ReadConnectv1ConnectorCalls returns the calls made to ReadConnectv1Connector.

func (*ConnectorsConnectV1Api) ReadConnectv1ConnectorExecute added in v0.5.0 

func (m *ConnectorsConnectV1Api) ReadConnectv1ConnectorExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1Connector, *net_http.Response, error)

ReadConnectv1ConnectorExecute mocks base method by wrapping the associated func.

func (*ConnectorsConnectV1Api) ReadConnectv1ConnectorExecuteCalled added in v0.5.0 

func (m *ConnectorsConnectV1Api) ReadConnectv1ConnectorExecuteCalled() bool

ReadConnectv1ConnectorExecuteCalled returns true if ReadConnectv1ConnectorExecute was called at least once.

func (*ConnectorsConnectV1Api) ReadConnectv1ConnectorExecuteCalls added in v0.5.0 

func (m *ConnectorsConnectV1Api) ReadConnectv1ConnectorExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorRequest
}

ReadConnectv1ConnectorExecuteCalls returns the calls made to ReadConnectv1ConnectorExecute.

func (*ConnectorsConnectV1Api) Reset added in v0.5.0 

func (m *ConnectorsConnectV1Api) Reset()

Reset resets the calls made to the mocked methods.

type LifecycleConnectV1Api added in v0.5.0 

type LifecycleConnectV1Api struct {
	PauseConnectv1ConnectorFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiPauseConnectv1ConnectorRequest

	PauseConnectv1ConnectorExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiPauseConnectv1ConnectorRequest) (*net_http.Response, error)

	ResumeConnectv1ConnectorFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiResumeConnectv1ConnectorRequest

	ResumeConnectv1ConnectorExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiResumeConnectv1ConnectorRequest) (*net_http.Response, error)
	// contains filtered or unexported fields
}

LifecycleConnectV1Api is a mock of LifecycleConnectV1Api interface

func (*LifecycleConnectV1Api) PauseConnectv1Connector added in v0.5.0 

func (m *LifecycleConnectV1Api) PauseConnectv1Connector(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiPauseConnectv1ConnectorRequest

PauseConnectv1Connector mocks base method by wrapping the associated func.

func (*LifecycleConnectV1Api) PauseConnectv1ConnectorCalled added in v0.5.0 

func (m *LifecycleConnectV1Api) PauseConnectv1ConnectorCalled() bool

PauseConnectv1ConnectorCalled returns true if PauseConnectv1Connector was called at least once.

func (*LifecycleConnectV1Api) PauseConnectv1ConnectorCalls added in v0.5.0 

func (m *LifecycleConnectV1Api) PauseConnectv1ConnectorCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

PauseConnectv1ConnectorCalls returns the calls made to PauseConnectv1Connector.

func (*LifecycleConnectV1Api) PauseConnectv1ConnectorExecute added in v0.5.0 

func (m *LifecycleConnectV1Api) PauseConnectv1ConnectorExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiPauseConnectv1ConnectorRequest) (*net_http.Response, error)

PauseConnectv1ConnectorExecute mocks base method by wrapping the associated func.

func (*LifecycleConnectV1Api) PauseConnectv1ConnectorExecuteCalled added in v0.5.0 

func (m *LifecycleConnectV1Api) PauseConnectv1ConnectorExecuteCalled() bool

PauseConnectv1ConnectorExecuteCalled returns true if PauseConnectv1ConnectorExecute was called at least once.

func (*LifecycleConnectV1Api) PauseConnectv1ConnectorExecuteCalls added in v0.5.0 

func (m *LifecycleConnectV1Api) PauseConnectv1ConnectorExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiPauseConnectv1ConnectorRequest
}

PauseConnectv1ConnectorExecuteCalls returns the calls made to PauseConnectv1ConnectorExecute.

func (*LifecycleConnectV1Api) Reset added in v0.5.0 

func (m *LifecycleConnectV1Api) Reset()

Reset resets the calls made to the mocked methods.

func (*LifecycleConnectV1Api) ResumeConnectv1Connector added in v0.5.0 

func (m *LifecycleConnectV1Api) ResumeConnectv1Connector(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiResumeConnectv1ConnectorRequest

ResumeConnectv1Connector mocks base method by wrapping the associated func.

func (*LifecycleConnectV1Api) ResumeConnectv1ConnectorCalled added in v0.5.0 

func (m *LifecycleConnectV1Api) ResumeConnectv1ConnectorCalled() bool

ResumeConnectv1ConnectorCalled returns true if ResumeConnectv1Connector was called at least once.

func (*LifecycleConnectV1Api) ResumeConnectv1ConnectorCalls added in v0.5.0 

func (m *LifecycleConnectV1Api) ResumeConnectv1ConnectorCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

ResumeConnectv1ConnectorCalls returns the calls made to ResumeConnectv1Connector.

func (*LifecycleConnectV1Api) ResumeConnectv1ConnectorExecute added in v0.5.0 

func (m *LifecycleConnectV1Api) ResumeConnectv1ConnectorExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiResumeConnectv1ConnectorRequest) (*net_http.Response, error)

ResumeConnectv1ConnectorExecute mocks base method by wrapping the associated func.

func (*LifecycleConnectV1Api) ResumeConnectv1ConnectorExecuteCalled added in v0.5.0 

func (m *LifecycleConnectV1Api) ResumeConnectv1ConnectorExecuteCalled() bool

ResumeConnectv1ConnectorExecuteCalled returns true if ResumeConnectv1ConnectorExecute was called at least once.

func (*LifecycleConnectV1Api) ResumeConnectv1ConnectorExecuteCalls added in v0.5.0 

func (m *LifecycleConnectV1Api) ResumeConnectv1ConnectorExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiResumeConnectv1ConnectorRequest
}

ResumeConnectv1ConnectorExecuteCalls returns the calls made to ResumeConnectv1ConnectorExecute.

type ManagedConnectorPluginsConnectV1Api added in v0.5.0 

type ManagedConnectorPluginsConnectV1Api struct {
	ListConnectv1ConnectorPluginsFunc func(ctx context.Context, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorPluginsRequest

	ListConnectv1ConnectorPluginsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorPluginsRequest) ([]github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.InlineResponse2002, *net_http.Response, error)

	ValidateConnectv1ConnectorPluginFunc func(ctx context.Context, pluginName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiValidateConnectv1ConnectorPluginRequest

	ValidateConnectv1ConnectorPluginExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiValidateConnectv1ConnectorPluginRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.InlineResponse2003, *net_http.Response, error)
	// contains filtered or unexported fields
}

ManagedConnectorPluginsConnectV1Api is a mock of ManagedConnectorPluginsConnectV1Api interface

func (*ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPlugins added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPlugins(ctx context.Context, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorPluginsRequest

ListConnectv1ConnectorPlugins mocks base method by wrapping the associated func.

func (*ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsCalled added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsCalled() bool

ListConnectv1ConnectorPluginsCalled returns true if ListConnectv1ConnectorPlugins was called at least once.

func (*ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsCalls added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsCalls() []struct {
	Ctx            context.Context
	EnvironmentId  string
	KafkaClusterId string
}

ListConnectv1ConnectorPluginsCalls returns the calls made to ListConnectv1ConnectorPlugins.

func (*ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsExecute added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorPluginsRequest) ([]github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.InlineResponse2002, *net_http.Response, error)

ListConnectv1ConnectorPluginsExecute mocks base method by wrapping the associated func.

func (*ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsExecuteCalled added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsExecuteCalled() bool

ListConnectv1ConnectorPluginsExecuteCalled returns true if ListConnectv1ConnectorPluginsExecute was called at least once.

func (*ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsExecuteCalls added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ListConnectv1ConnectorPluginsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorPluginsRequest
}

ListConnectv1ConnectorPluginsExecuteCalls returns the calls made to ListConnectv1ConnectorPluginsExecute.

func (*ManagedConnectorPluginsConnectV1Api) Reset added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) Reset()

Reset resets the calls made to the mocked methods.

func (*ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPlugin added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPlugin(ctx context.Context, pluginName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiValidateConnectv1ConnectorPluginRequest

ValidateConnectv1ConnectorPlugin mocks base method by wrapping the associated func.

func (*ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginCalled added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginCalled() bool

ValidateConnectv1ConnectorPluginCalled returns true if ValidateConnectv1ConnectorPlugin was called at least once.

func (*ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginCalls added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginCalls() []struct {
	Ctx            context.Context
	PluginName     string
	EnvironmentId  string
	KafkaClusterId string
}

ValidateConnectv1ConnectorPluginCalls returns the calls made to ValidateConnectv1ConnectorPlugin.

func (*ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginExecute added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiValidateConnectv1ConnectorPluginRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.InlineResponse2003, *net_http.Response, error)

ValidateConnectv1ConnectorPluginExecute mocks base method by wrapping the associated func.

func (*ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginExecuteCalled added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginExecuteCalled() bool

ValidateConnectv1ConnectorPluginExecuteCalled returns true if ValidateConnectv1ConnectorPluginExecute was called at least once.

func (*ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginExecuteCalls added in v0.5.0 

func (m *ManagedConnectorPluginsConnectV1Api) ValidateConnectv1ConnectorPluginExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiValidateConnectv1ConnectorPluginRequest
}

ValidateConnectv1ConnectorPluginExecuteCalls returns the calls made to ValidateConnectv1ConnectorPluginExecute.

type OffsetsConnectV1Api added in v0.5.0 

type OffsetsConnectV1Api struct {
	AlterConnectv1ConnectorOffsetsRequestFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiAlterConnectv1ConnectorOffsetsRequestRequest

	AlterConnectv1ConnectorOffsetsRequestExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiAlterConnectv1ConnectorOffsetsRequestRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1AlterOffsetRequestInfo, *net_http.Response, error)

	GetConnectv1ConnectorOffsetsFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequest

	GetConnectv1ConnectorOffsetsExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1ConnectorOffsets, *net_http.Response, error)

	GetConnectv1ConnectorOffsetsRequestStatusFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequestStatusRequest

	GetConnectv1ConnectorOffsetsRequestStatusExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequestStatusRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1AlterOffsetStatus, *net_http.Response, error)
	// contains filtered or unexported fields
}

OffsetsConnectV1Api is a mock of OffsetsConnectV1Api interface

func (*OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequest added in v0.5.0 

func (m *OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequest(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiAlterConnectv1ConnectorOffsetsRequestRequest

AlterConnectv1ConnectorOffsetsRequest mocks base method by wrapping the associated func.

func (*OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestCalled added in v0.5.0 

func (m *OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestCalled() bool

AlterConnectv1ConnectorOffsetsRequestCalled returns true if AlterConnectv1ConnectorOffsetsRequest was called at least once.

func (*OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestCalls added in v0.5.0 

func (m *OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

AlterConnectv1ConnectorOffsetsRequestCalls returns the calls made to AlterConnectv1ConnectorOffsetsRequest.

func (*OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestExecute added in v0.5.0 

func (m *OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiAlterConnectv1ConnectorOffsetsRequestRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1AlterOffsetRequestInfo, *net_http.Response, error)

AlterConnectv1ConnectorOffsetsRequestExecute mocks base method by wrapping the associated func.

func (*OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestExecuteCalled added in v0.5.0 

func (m *OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestExecuteCalled() bool

AlterConnectv1ConnectorOffsetsRequestExecuteCalled returns true if AlterConnectv1ConnectorOffsetsRequestExecute was called at least once.

func (*OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestExecuteCalls added in v0.5.0 

func (m *OffsetsConnectV1Api) AlterConnectv1ConnectorOffsetsRequestExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiAlterConnectv1ConnectorOffsetsRequestRequest
}

AlterConnectv1ConnectorOffsetsRequestExecuteCalls returns the calls made to AlterConnectv1ConnectorOffsetsRequestExecute.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsets added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsets(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequest

GetConnectv1ConnectorOffsets mocks base method by wrapping the associated func.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsCalled added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsCalled() bool

GetConnectv1ConnectorOffsetsCalled returns true if GetConnectv1ConnectorOffsets was called at least once.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsCalls added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

GetConnectv1ConnectorOffsetsCalls returns the calls made to GetConnectv1ConnectorOffsets.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsExecute added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1ConnectorOffsets, *net_http.Response, error)

GetConnectv1ConnectorOffsetsExecute mocks base method by wrapping the associated func.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsExecuteCalled added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsExecuteCalled() bool

GetConnectv1ConnectorOffsetsExecuteCalled returns true if GetConnectv1ConnectorOffsetsExecute was called at least once.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsExecuteCalls added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequest
}

GetConnectv1ConnectorOffsetsExecuteCalls returns the calls made to GetConnectv1ConnectorOffsetsExecute.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatus added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatus(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequestStatusRequest

GetConnectv1ConnectorOffsetsRequestStatus mocks base method by wrapping the associated func.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusCalled added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusCalled() bool

GetConnectv1ConnectorOffsetsRequestStatusCalled returns true if GetConnectv1ConnectorOffsetsRequestStatus was called at least once.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusCalls added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

GetConnectv1ConnectorOffsetsRequestStatusCalls returns the calls made to GetConnectv1ConnectorOffsetsRequestStatus.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusExecute added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequestStatusRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ConnectV1AlterOffsetStatus, *net_http.Response, error)

GetConnectv1ConnectorOffsetsRequestStatusExecute mocks base method by wrapping the associated func.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusExecuteCalled added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusExecuteCalled() bool

GetConnectv1ConnectorOffsetsRequestStatusExecuteCalled returns true if GetConnectv1ConnectorOffsetsRequestStatusExecute was called at least once.

func (*OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusExecuteCalls added in v0.5.0 

func (m *OffsetsConnectV1Api) GetConnectv1ConnectorOffsetsRequestStatusExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiGetConnectv1ConnectorOffsetsRequestStatusRequest
}

GetConnectv1ConnectorOffsetsRequestStatusExecuteCalls returns the calls made to GetConnectv1ConnectorOffsetsRequestStatusExecute.

func (*OffsetsConnectV1Api) Reset added in v0.5.0 

func (m *OffsetsConnectV1Api) Reset()

Reset resets the calls made to the mocked methods.

type StatusConnectV1Api added in v0.5.0 

type StatusConnectV1Api struct {
	ListConnectv1ConnectorTasksFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorTasksRequest

	ListConnectv1ConnectorTasksExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorTasksRequest) ([]map[string]interface{}, *net_http.Response, error)

	ReadConnectv1ConnectorStatusFunc func(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorStatusRequest

	ReadConnectv1ConnectorStatusExecuteFunc func(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorStatusRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.InlineResponse2001, *net_http.Response, error)
	// contains filtered or unexported fields
}

StatusConnectV1Api is a mock of StatusConnectV1Api interface

func (*StatusConnectV1Api) ListConnectv1ConnectorTasks added in v0.5.0 

func (m *StatusConnectV1Api) ListConnectv1ConnectorTasks(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorTasksRequest

ListConnectv1ConnectorTasks mocks base method by wrapping the associated func.

func (*StatusConnectV1Api) ListConnectv1ConnectorTasksCalled added in v0.5.0 

func (m *StatusConnectV1Api) ListConnectv1ConnectorTasksCalled() bool

ListConnectv1ConnectorTasksCalled returns true if ListConnectv1ConnectorTasks was called at least once.

func (*StatusConnectV1Api) ListConnectv1ConnectorTasksCalls added in v0.5.0 

func (m *StatusConnectV1Api) ListConnectv1ConnectorTasksCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

ListConnectv1ConnectorTasksCalls returns the calls made to ListConnectv1ConnectorTasks.

func (*StatusConnectV1Api) ListConnectv1ConnectorTasksExecute added in v0.5.0 

func (m *StatusConnectV1Api) ListConnectv1ConnectorTasksExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorTasksRequest) ([]map[string]interface{}, *net_http.Response, error)

ListConnectv1ConnectorTasksExecute mocks base method by wrapping the associated func.

func (*StatusConnectV1Api) ListConnectv1ConnectorTasksExecuteCalled added in v0.5.0 

func (m *StatusConnectV1Api) ListConnectv1ConnectorTasksExecuteCalled() bool

ListConnectv1ConnectorTasksExecuteCalled returns true if ListConnectv1ConnectorTasksExecute was called at least once.

func (*StatusConnectV1Api) ListConnectv1ConnectorTasksExecuteCalls added in v0.5.0 

func (m *StatusConnectV1Api) ListConnectv1ConnectorTasksExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiListConnectv1ConnectorTasksRequest
}

ListConnectv1ConnectorTasksExecuteCalls returns the calls made to ListConnectv1ConnectorTasksExecute.

func (*StatusConnectV1Api) ReadConnectv1ConnectorStatus added in v0.5.0 

func (m *StatusConnectV1Api) ReadConnectv1ConnectorStatus(ctx context.Context, connectorName, environmentId, kafkaClusterId string) github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorStatusRequest

ReadConnectv1ConnectorStatus mocks base method by wrapping the associated func.

func (*StatusConnectV1Api) ReadConnectv1ConnectorStatusCalled added in v0.5.0 

func (m *StatusConnectV1Api) ReadConnectv1ConnectorStatusCalled() bool

ReadConnectv1ConnectorStatusCalled returns true if ReadConnectv1ConnectorStatus was called at least once.

func (*StatusConnectV1Api) ReadConnectv1ConnectorStatusCalls added in v0.5.0 

func (m *StatusConnectV1Api) ReadConnectv1ConnectorStatusCalls() []struct {
	Ctx            context.Context
	ConnectorName  string
	EnvironmentId  string
	KafkaClusterId string
}

ReadConnectv1ConnectorStatusCalls returns the calls made to ReadConnectv1ConnectorStatus.

func (*StatusConnectV1Api) ReadConnectv1ConnectorStatusExecute added in v0.5.0 

func (m *StatusConnectV1Api) ReadConnectv1ConnectorStatusExecute(r github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorStatusRequest) (github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.InlineResponse2001, *net_http.Response, error)

ReadConnectv1ConnectorStatusExecute mocks base method by wrapping the associated func.

func (*StatusConnectV1Api) ReadConnectv1ConnectorStatusExecuteCalled added in v0.5.0 

func (m *StatusConnectV1Api) ReadConnectv1ConnectorStatusExecuteCalled() bool

ReadConnectv1ConnectorStatusExecuteCalled returns true if ReadConnectv1ConnectorStatusExecute was called at least once.

func (*StatusConnectV1Api) ReadConnectv1ConnectorStatusExecuteCalls added in v0.5.0 

func (m *StatusConnectV1Api) ReadConnectv1ConnectorStatusExecuteCalls() []struct {
	R github_com_confluentinc_ccloud_sdk_go_v2_connect_v1.ApiReadConnectv1ConnectorStatusRequest
}

ReadConnectv1ConnectorStatusExecuteCalls returns the calls made to ReadConnectv1ConnectorStatusExecute.

func (*StatusConnectV1Api) Reset added in v0.5.0 

func (m *StatusConnectV1Api) Reset()

Reset resets the calls made to the mocked methods.

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.