Some or all of the information on this page might not apply to Cloud de Confiance by S3NS. See Differences from Google Cloud for more details.

Managed Service for Apache Kafka API v1 API - Class ManagedKafkaConnect.ManagedKafkaConnectBase (1.0.0-beta07)

[BindServiceMethod(typeof(ManagedKafkaConnect), "BindService")]
public abstract class ManagedKafkaConnect.ManagedKafkaConnectBase

Reference documentation and code samples for the Managed Service for Apache Kafka API v1 API class ManagedKafkaConnect.ManagedKafkaConnectBase.

Base class for server-side implementations of ManagedKafkaConnect

Inheritance

object > ManagedKafkaConnect.ManagedKafkaConnectBase

Inherited Members

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ToString()

Namespace

Google.Cloud.ManagedKafka.V1

Assembly

Google.Cloud.ManagedKafka.V1.dll

Methods

CreateConnectCluster(CreateConnectClusterRequest, ServerCallContext)

public virtual Task<Operation> CreateConnectCluster(CreateConnectClusterRequest request, ServerCallContext context)

Creates a new Kafka Connect cluster in a given project and location.

Parameters
Name	Description
`request`	`CreateConnectClusterRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskOperation`	The response to send back to the client (wrapped by a task).

CreateConnector(CreateConnectorRequest, ServerCallContext)

public virtual Task<Connector> CreateConnector(CreateConnectorRequest request, ServerCallContext context)

Creates a new connector in a given Connect cluster.

Parameters
Name	Description
`request`	`CreateConnectorRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskConnector`	The response to send back to the client (wrapped by a task).

DeleteConnectCluster(DeleteConnectClusterRequest, ServerCallContext)

public virtual Task<Operation> DeleteConnectCluster(DeleteConnectClusterRequest request, ServerCallContext context)

Deletes a single Connect cluster.

Parameters
Name	Description
`request`	`DeleteConnectClusterRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskOperation`	The response to send back to the client (wrapped by a task).

DeleteConnector(DeleteConnectorRequest, ServerCallContext)

public virtual Task<Empty> DeleteConnector(DeleteConnectorRequest request, ServerCallContext context)

Deletes a connector.

Parameters
Name	Description
`request`	`DeleteConnectorRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskEmpty`	The response to send back to the client (wrapped by a task).

GetConnectCluster(GetConnectClusterRequest, ServerCallContext)

public virtual Task<ConnectCluster> GetConnectCluster(GetConnectClusterRequest request, ServerCallContext context)

Returns the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`GetConnectClusterRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskConnectCluster`	The response to send back to the client (wrapped by a task).

GetConnector(GetConnectorRequest, ServerCallContext)

public virtual Task<Connector> GetConnector(GetConnectorRequest request, ServerCallContext context)

Returns the properties of a single connector.

Parameters
Name	Description
`request`	`GetConnectorRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskConnector`	The response to send back to the client (wrapped by a task).

ListConnectClusters(ListConnectClustersRequest, ServerCallContext)

public virtual Task<ListConnectClustersResponse> ListConnectClusters(ListConnectClustersRequest request, ServerCallContext context)

Lists the Kafka Connect clusters in a given project and location.

Parameters
Name	Description
`request`	`ListConnectClustersRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskListConnectClustersResponse`	The response to send back to the client (wrapped by a task).

ListConnectors(ListConnectorsRequest, ServerCallContext)

public virtual Task<ListConnectorsResponse> ListConnectors(ListConnectorsRequest request, ServerCallContext context)

Lists the connectors in a given Connect cluster.

Parameters
Name	Description
`request`	`ListConnectorsRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskListConnectorsResponse`	The response to send back to the client (wrapped by a task).

PauseConnector(PauseConnectorRequest, ServerCallContext)

public virtual Task<PauseConnectorResponse> PauseConnector(PauseConnectorRequest request, ServerCallContext context)

Pauses the connector and its tasks.

Parameters
Name	Description
`request`	`PauseConnectorRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskPauseConnectorResponse`	The response to send back to the client (wrapped by a task).

RestartConnector(RestartConnectorRequest, ServerCallContext)

public virtual Task<RestartConnectorResponse> RestartConnector(RestartConnectorRequest request, ServerCallContext context)

Restarts the connector.

Parameters
Name	Description
`request`	`RestartConnectorRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskRestartConnectorResponse`	The response to send back to the client (wrapped by a task).

ResumeConnector(ResumeConnectorRequest, ServerCallContext)

public virtual Task<ResumeConnectorResponse> ResumeConnector(ResumeConnectorRequest request, ServerCallContext context)

Resumes the connector and its tasks.

Parameters
Name	Description
`request`	`ResumeConnectorRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskResumeConnectorResponse`	The response to send back to the client (wrapped by a task).

StopConnector(StopConnectorRequest, ServerCallContext)

public virtual Task<StopConnectorResponse> StopConnector(StopConnectorRequest request, ServerCallContext context)

Stops the connector.

Parameters
Name	Description
`request`	`StopConnectorRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskStopConnectorResponse`	The response to send back to the client (wrapped by a task).

UpdateConnectCluster(UpdateConnectClusterRequest, ServerCallContext)

public virtual Task<Operation> UpdateConnectCluster(UpdateConnectClusterRequest request, ServerCallContext context)

Updates the properties of a single Kafka Connect cluster.

Parameters
Name	Description
`request`	`UpdateConnectClusterRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskOperation`	The response to send back to the client (wrapped by a task).

UpdateConnector(UpdateConnectorRequest, ServerCallContext)

public virtual Task<Connector> UpdateConnector(UpdateConnectorRequest request, ServerCallContext context)

Updates the properties of a connector.

Parameters
Name	Description
`request`	`UpdateConnectorRequest` The request received from the client.
`context`	`ServerCallContext` The context of the server-side call handler being invoked.

Returns
Type	Description
`TaskConnector`	The response to send back to the client (wrapped by a task).