Managed Service for Apache Kafka API v1 API - Class ManagedKafkaConnect.ManagedKafkaConnectBase (1.0.0-beta05)
Stay organized with collections Save and categorize content based on your preferences.

[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).

Managed Service for Apache Kafka API v1 API - Class ManagedKafkaConnect.ManagedKafkaConnectBase (1.0.0-beta05) Stay organized with collections Save and categorize content based on your preferences.