Class protos.google.cloud.managedkafka.v1.ManagedKafkaConnect (0.6.0)

Represents a ManagedKafkaConnect

Inheritance

$protobuf.rpc.Service > protos.google.cloud.managedkafka.v1.ManagedKafkaConnect

Package

@google-cloud/managedkafka

Constructors

(constructor)(rpcImpl, requestDelimited, responseDelimited)

constructor(rpcImpl: $protobuf.RPCImpl, requestDelimited?: boolean, responseDelimited?: boolean);

Constructs a new ManagedKafkaConnect service.

Parameters
Name Description
rpcImpl $protobuf.RPCImpl

RPC implementation
requestDelimited boolean

Whether requests are length-delimited
responseDelimited boolean

Whether responses are length-delimited

Methods

create(rpcImpl, requestDelimited, responseDelimited)

public static create(rpcImpl: $protobuf.RPCImpl, requestDelimited?: boolean, responseDelimited?: boolean): ManagedKafkaConnect;

Creates new ManagedKafkaConnect service using the specified rpc implementation.

Parameters
Name Description
rpcImpl $protobuf.RPCImpl

RPC implementation
requestDelimited boolean

Whether requests are length-delimited
responseDelimited boolean

Whether responses are length-delimited
Returns
Type Description
ManagedKafkaConnect

RPC service. Useful where requests and/or responses are streamed.

createConnectCluster(request, callback)

public createConnectCluster(request: google.cloud.managedkafka.v1.ICreateConnectClusterRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.CreateConnectClusterCallback): void;

Calls CreateConnectCluster.

Parameters
Name Description
request ICreateConnectClusterRequest

CreateConnectClusterRequest message or plain object
callback CreateConnectClusterCallback

Node-style callback called with the error, if any, and Operation
Returns
Type Description
void

createConnectCluster(request)

public createConnectCluster(request: google.cloud.managedkafka.v1.ICreateConnectClusterRequest): Promise<google.longrunning.Operation>;

Calls CreateConnectCluster.

Parameter
Name Description
request ICreateConnectClusterRequest

CreateConnectClusterRequest message or plain object
Returns
Type Description
Promise<google.longrunning.Operation>

Promise

createConnector(request, callback)

public createConnector(request: google.cloud.managedkafka.v1.ICreateConnectorRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.CreateConnectorCallback): void;

Calls CreateConnector.

Parameters
Name Description
request ICreateConnectorRequest

CreateConnectorRequest message or plain object
callback CreateConnectorCallback

Node-style callback called with the error, if any, and Connector
Returns
Type Description
void

createConnector(request)

public createConnector(request: google.cloud.managedkafka.v1.ICreateConnectorRequest): Promise<google.cloud.managedkafka.v1.Connector>;

Calls CreateConnector.

Parameter
Name Description
request ICreateConnectorRequest

CreateConnectorRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.Connector>

Promise

deleteConnectCluster(request, callback)

public deleteConnectCluster(request: google.cloud.managedkafka.v1.IDeleteConnectClusterRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.DeleteConnectClusterCallback): void;

Calls DeleteConnectCluster.

Parameters
Name Description
request IDeleteConnectClusterRequest

DeleteConnectClusterRequest message or plain object
callback DeleteConnectClusterCallback

Node-style callback called with the error, if any, and Operation
Returns
Type Description
void

deleteConnectCluster(request)

public deleteConnectCluster(request: google.cloud.managedkafka.v1.IDeleteConnectClusterRequest): Promise<google.longrunning.Operation>;

Calls DeleteConnectCluster.

Parameter
Name Description
request IDeleteConnectClusterRequest

DeleteConnectClusterRequest message or plain object
Returns
Type Description
Promise<google.longrunning.Operation>

Promise

deleteConnector(request, callback)

public deleteConnector(request: google.cloud.managedkafka.v1.IDeleteConnectorRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.DeleteConnectorCallback): void;

Calls DeleteConnector.

Parameters
Name Description
request IDeleteConnectorRequest

DeleteConnectorRequest message or plain object
callback DeleteConnectorCallback

Node-style callback called with the error, if any, and Empty
Returns
Type Description
void

deleteConnector(request)

public deleteConnector(request: google.cloud.managedkafka.v1.IDeleteConnectorRequest): Promise<google.protobuf.Empty>;

Calls DeleteConnector.

Parameter
Name Description
request IDeleteConnectorRequest

DeleteConnectorRequest message or plain object
Returns
Type Description
Promise<google.protobuf.Empty>

Promise

getConnectCluster(request, callback)

public getConnectCluster(request: google.cloud.managedkafka.v1.IGetConnectClusterRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.GetConnectClusterCallback): void;

Calls GetConnectCluster.

Parameters
Name Description
request IGetConnectClusterRequest

GetConnectClusterRequest message or plain object
callback GetConnectClusterCallback

Node-style callback called with the error, if any, and ConnectCluster
Returns
Type Description
void

getConnectCluster(request)

public getConnectCluster(request: google.cloud.managedkafka.v1.IGetConnectClusterRequest): Promise<google.cloud.managedkafka.v1.ConnectCluster>;

Calls GetConnectCluster.

Parameter
Name Description
request IGetConnectClusterRequest

GetConnectClusterRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.ConnectCluster>

Promise

getConnector(request, callback)

public getConnector(request: google.cloud.managedkafka.v1.IGetConnectorRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.GetConnectorCallback): void;

Calls GetConnector.

Parameters
Name Description
request IGetConnectorRequest

GetConnectorRequest message or plain object
callback GetConnectorCallback

Node-style callback called with the error, if any, and Connector
Returns
Type Description
void

getConnector(request)

public getConnector(request: google.cloud.managedkafka.v1.IGetConnectorRequest): Promise<google.cloud.managedkafka.v1.Connector>;

Calls GetConnector.

Parameter
Name Description
request IGetConnectorRequest

GetConnectorRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.Connector>

Promise

listConnectClusters(request, callback)

public listConnectClusters(request: google.cloud.managedkafka.v1.IListConnectClustersRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.ListConnectClustersCallback): void;

Calls ListConnectClusters.

Parameters
Name Description
request IListConnectClustersRequest

ListConnectClustersRequest message or plain object
callback ListConnectClustersCallback

Node-style callback called with the error, if any, and ListConnectClustersResponse
Returns
Type Description
void

listConnectClusters(request)

public listConnectClusters(request: google.cloud.managedkafka.v1.IListConnectClustersRequest): Promise<google.cloud.managedkafka.v1.ListConnectClustersResponse>;

Calls ListConnectClusters.

Parameter
Name Description
request IListConnectClustersRequest

ListConnectClustersRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.ListConnectClustersResponse>

Promise

listConnectors(request, callback)

public listConnectors(request: google.cloud.managedkafka.v1.IListConnectorsRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.ListConnectorsCallback): void;

Calls ListConnectors.

Parameters
Name Description
request IListConnectorsRequest

ListConnectorsRequest message or plain object
callback ListConnectorsCallback

Node-style callback called with the error, if any, and ListConnectorsResponse
Returns
Type Description
void

listConnectors(request)

public listConnectors(request: google.cloud.managedkafka.v1.IListConnectorsRequest): Promise<google.cloud.managedkafka.v1.ListConnectorsResponse>;

Calls ListConnectors.

Parameter
Name Description
request IListConnectorsRequest

ListConnectorsRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.ListConnectorsResponse>

Promise

pauseConnector(request, callback)

public pauseConnector(request: google.cloud.managedkafka.v1.IPauseConnectorRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.PauseConnectorCallback): void;

Calls PauseConnector.

Parameters
Name Description
request IPauseConnectorRequest

PauseConnectorRequest message or plain object
callback PauseConnectorCallback

Node-style callback called with the error, if any, and PauseConnectorResponse
Returns
Type Description
void

pauseConnector(request)

public pauseConnector(request: google.cloud.managedkafka.v1.IPauseConnectorRequest): Promise<google.cloud.managedkafka.v1.PauseConnectorResponse>;

Calls PauseConnector.

Parameter
Name Description
request IPauseConnectorRequest

PauseConnectorRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.PauseConnectorResponse>

Promise

restartConnector(request, callback)

public restartConnector(request: google.cloud.managedkafka.v1.IRestartConnectorRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.RestartConnectorCallback): void;

Calls RestartConnector.

Parameters
Name Description
request IRestartConnectorRequest

RestartConnectorRequest message or plain object
callback RestartConnectorCallback

Node-style callback called with the error, if any, and RestartConnectorResponse
Returns
Type Description
void

restartConnector(request)

public restartConnector(request: google.cloud.managedkafka.v1.IRestartConnectorRequest): Promise<google.cloud.managedkafka.v1.RestartConnectorResponse>;

Calls RestartConnector.

Parameter
Name Description
request IRestartConnectorRequest

RestartConnectorRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.RestartConnectorResponse>

Promise

resumeConnector(request, callback)

public resumeConnector(request: google.cloud.managedkafka.v1.IResumeConnectorRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.ResumeConnectorCallback): void;

Calls ResumeConnector.

Parameters
Name Description
request IResumeConnectorRequest

ResumeConnectorRequest message or plain object
callback ResumeConnectorCallback

Node-style callback called with the error, if any, and ResumeConnectorResponse
Returns
Type Description
void

resumeConnector(request)

public resumeConnector(request: google.cloud.managedkafka.v1.IResumeConnectorRequest): Promise<google.cloud.managedkafka.v1.ResumeConnectorResponse>;

Calls ResumeConnector.

Parameter
Name Description
request IResumeConnectorRequest

ResumeConnectorRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.ResumeConnectorResponse>

Promise

stopConnector(request, callback)

public stopConnector(request: google.cloud.managedkafka.v1.IStopConnectorRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.StopConnectorCallback): void;

Calls StopConnector.

Parameters
Name Description
request IStopConnectorRequest

StopConnectorRequest message or plain object
callback StopConnectorCallback

Node-style callback called with the error, if any, and StopConnectorResponse
Returns
Type Description
void

stopConnector(request)

public stopConnector(request: google.cloud.managedkafka.v1.IStopConnectorRequest): Promise<google.cloud.managedkafka.v1.StopConnectorResponse>;

Calls StopConnector.

Parameter
Name Description
request IStopConnectorRequest

StopConnectorRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.StopConnectorResponse>

Promise

updateConnectCluster(request, callback)

public updateConnectCluster(request: google.cloud.managedkafka.v1.IUpdateConnectClusterRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.UpdateConnectClusterCallback): void;

Calls UpdateConnectCluster.

Parameters
Name Description
request IUpdateConnectClusterRequest

UpdateConnectClusterRequest message or plain object
callback UpdateConnectClusterCallback

Node-style callback called with the error, if any, and Operation
Returns
Type Description
void

updateConnectCluster(request)

public updateConnectCluster(request: google.cloud.managedkafka.v1.IUpdateConnectClusterRequest): Promise<google.longrunning.Operation>;

Calls UpdateConnectCluster.

Parameter
Name Description
request IUpdateConnectClusterRequest

UpdateConnectClusterRequest message or plain object
Returns
Type Description
Promise<google.longrunning.Operation>

Promise

updateConnector(request, callback)

public updateConnector(request: google.cloud.managedkafka.v1.IUpdateConnectorRequest, callback: google.cloud.managedkafka.v1.ManagedKafkaConnect.UpdateConnectorCallback): void;

Calls UpdateConnector.

Parameters
Name Description
request IUpdateConnectorRequest

UpdateConnectorRequest message or plain object
callback UpdateConnectorCallback

Node-style callback called with the error, if any, and Connector
Returns
Type Description
void

updateConnector(request)

public updateConnector(request: google.cloud.managedkafka.v1.IUpdateConnectorRequest): Promise<google.cloud.managedkafka.v1.Connector>;

Calls UpdateConnector.

Parameter
Name Description
request IUpdateConnectorRequest

UpdateConnectorRequest message or plain object
Returns
Type Description
Promise<google.cloud.managedkafka.v1.Connector>

Promise