Class protos.google.cloud.managedkafka.v1.ManagedKafka (0.1.0)

Represents a ManagedKafka

Inheritance

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

Package

@google-cloud/managedkafka

Constructors

(constructor)(rpcImpl, requestDelimited, responseDelimited)

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

Constructs a new ManagedKafka 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): ManagedKafka;

Creates new ManagedKafka 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
ManagedKafka	RPC service. Useful where requests and/or responses are streamed.

createCluster(request, callback)

public createCluster(request: google.cloud.managedkafka.v1.ICreateClusterRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.CreateClusterCallback): void;

Calls CreateCluster.

Parameters
Name	Description
request	ICreateClusterRequest CreateClusterRequest message or plain object
callback	CreateClusterCallback Node-style callback called with the error, if any, and Operation

Returns
Type	Description
void

createCluster(request)

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

Calls CreateCluster.

Parameter
Name	Description
request	ICreateClusterRequest CreateClusterRequest message or plain object

Returns
Type	Description
Promise<google.longrunning.Operation>	Promise

createTopic(request, callback)

public createTopic(request: google.cloud.managedkafka.v1.ICreateTopicRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.CreateTopicCallback): void;

Calls CreateTopic.

Parameters
Name	Description
request	ICreateTopicRequest CreateTopicRequest message or plain object
callback	CreateTopicCallback Node-style callback called with the error, if any, and Topic

Returns
Type	Description
void

createTopic(request)

public createTopic(request: google.cloud.managedkafka.v1.ICreateTopicRequest): Promise<google.cloud.managedkafka.v1.Topic>;

Calls CreateTopic.

Parameter
Name	Description
request	ICreateTopicRequest CreateTopicRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.Topic>	Promise

deleteCluster(request, callback)

public deleteCluster(request: google.cloud.managedkafka.v1.IDeleteClusterRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.DeleteClusterCallback): void;

Calls DeleteCluster.

Parameters
Name	Description
request	IDeleteClusterRequest DeleteClusterRequest message or plain object
callback	DeleteClusterCallback Node-style callback called with the error, if any, and Operation

Returns
Type	Description
void

deleteCluster(request)

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

Calls DeleteCluster.

Parameter
Name	Description
request	IDeleteClusterRequest DeleteClusterRequest message or plain object

Returns
Type	Description
Promise<google.longrunning.Operation>	Promise

deleteConsumerGroup(request, callback)

public deleteConsumerGroup(request: google.cloud.managedkafka.v1.IDeleteConsumerGroupRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.DeleteConsumerGroupCallback): void;

Calls DeleteConsumerGroup.

Parameters
Name	Description
request	IDeleteConsumerGroupRequest DeleteConsumerGroupRequest message or plain object
callback	DeleteConsumerGroupCallback Node-style callback called with the error, if any, and Empty

Returns
Type	Description
void

deleteConsumerGroup(request)

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

Calls DeleteConsumerGroup.

Parameter
Name	Description
request	IDeleteConsumerGroupRequest DeleteConsumerGroupRequest message or plain object

Returns
Type	Description
Promise<google.protobuf.Empty>	Promise

deleteTopic(request, callback)

public deleteTopic(request: google.cloud.managedkafka.v1.IDeleteTopicRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.DeleteTopicCallback): void;

Calls DeleteTopic.

Parameters
Name	Description
request	IDeleteTopicRequest DeleteTopicRequest message or plain object
callback	DeleteTopicCallback Node-style callback called with the error, if any, and Empty

Returns
Type	Description
void

deleteTopic(request)

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

Calls DeleteTopic.

Parameter
Name	Description
request	IDeleteTopicRequest DeleteTopicRequest message or plain object

Returns
Type	Description
Promise<google.protobuf.Empty>	Promise

getCluster(request, callback)

public getCluster(request: google.cloud.managedkafka.v1.IGetClusterRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.GetClusterCallback): void;

Calls GetCluster.

Parameters
Name	Description
request	IGetClusterRequest GetClusterRequest message or plain object
callback	GetClusterCallback Node-style callback called with the error, if any, and Cluster

Returns
Type	Description
void

getCluster(request)

public getCluster(request: google.cloud.managedkafka.v1.IGetClusterRequest): Promise<google.cloud.managedkafka.v1.Cluster>;

Calls GetCluster.

Parameter
Name	Description
request	IGetClusterRequest GetClusterRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.Cluster>	Promise

getConsumerGroup(request, callback)

public getConsumerGroup(request: google.cloud.managedkafka.v1.IGetConsumerGroupRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.GetConsumerGroupCallback): void;

Calls GetConsumerGroup.

Parameters
Name	Description
request	IGetConsumerGroupRequest GetConsumerGroupRequest message or plain object
callback	GetConsumerGroupCallback Node-style callback called with the error, if any, and ConsumerGroup

Returns
Type	Description
void

getConsumerGroup(request)

public getConsumerGroup(request: google.cloud.managedkafka.v1.IGetConsumerGroupRequest): Promise<google.cloud.managedkafka.v1.ConsumerGroup>;

Calls GetConsumerGroup.

Parameter
Name	Description
request	IGetConsumerGroupRequest GetConsumerGroupRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.ConsumerGroup>	Promise

getTopic(request, callback)

public getTopic(request: google.cloud.managedkafka.v1.IGetTopicRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.GetTopicCallback): void;

Calls GetTopic.

Parameters
Name	Description
request	IGetTopicRequest GetTopicRequest message or plain object
callback	GetTopicCallback Node-style callback called with the error, if any, and Topic

Returns
Type	Description
void

getTopic(request)

public getTopic(request: google.cloud.managedkafka.v1.IGetTopicRequest): Promise<google.cloud.managedkafka.v1.Topic>;

Calls GetTopic.

Parameter
Name	Description
request	IGetTopicRequest GetTopicRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.Topic>	Promise

listClusters(request, callback)

public listClusters(request: google.cloud.managedkafka.v1.IListClustersRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.ListClustersCallback): void;

Calls ListClusters.

Parameters
Name	Description
request	IListClustersRequest ListClustersRequest message or plain object
callback	ListClustersCallback Node-style callback called with the error, if any, and ListClustersResponse

Returns
Type	Description
void

listClusters(request)

public listClusters(request: google.cloud.managedkafka.v1.IListClustersRequest): Promise<google.cloud.managedkafka.v1.ListClustersResponse>;

Calls ListClusters.

Parameter
Name	Description
request	IListClustersRequest ListClustersRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.ListClustersResponse>	Promise

listConsumerGroups(request, callback)

public listConsumerGroups(request: google.cloud.managedkafka.v1.IListConsumerGroupsRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.ListConsumerGroupsCallback): void;

Calls ListConsumerGroups.

Parameters
Name	Description
request	IListConsumerGroupsRequest ListConsumerGroupsRequest message or plain object
callback	ListConsumerGroupsCallback Node-style callback called with the error, if any, and ListConsumerGroupsResponse

Returns
Type	Description
void

listConsumerGroups(request)

public listConsumerGroups(request: google.cloud.managedkafka.v1.IListConsumerGroupsRequest): Promise<google.cloud.managedkafka.v1.ListConsumerGroupsResponse>;

Calls ListConsumerGroups.

Parameter
Name	Description
request	IListConsumerGroupsRequest ListConsumerGroupsRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.ListConsumerGroupsResponse>	Promise

listTopics(request, callback)

public listTopics(request: google.cloud.managedkafka.v1.IListTopicsRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.ListTopicsCallback): void;

Calls ListTopics.

Parameters
Name	Description
request	IListTopicsRequest ListTopicsRequest message or plain object
callback	ListTopicsCallback Node-style callback called with the error, if any, and ListTopicsResponse

Returns
Type	Description
void

listTopics(request)

public listTopics(request: google.cloud.managedkafka.v1.IListTopicsRequest): Promise<google.cloud.managedkafka.v1.ListTopicsResponse>;

Calls ListTopics.

Parameter
Name	Description
request	IListTopicsRequest ListTopicsRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.ListTopicsResponse>	Promise

updateCluster(request, callback)

public updateCluster(request: google.cloud.managedkafka.v1.IUpdateClusterRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.UpdateClusterCallback): void;

Calls UpdateCluster.

Parameters
Name	Description
request	IUpdateClusterRequest UpdateClusterRequest message or plain object
callback	UpdateClusterCallback Node-style callback called with the error, if any, and Operation

Returns
Type	Description
void

updateCluster(request)

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

Calls UpdateCluster.

Parameter
Name	Description
request	IUpdateClusterRequest UpdateClusterRequest message or plain object

Returns
Type	Description
Promise<google.longrunning.Operation>	Promise

updateConsumerGroup(request, callback)

public updateConsumerGroup(request: google.cloud.managedkafka.v1.IUpdateConsumerGroupRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.UpdateConsumerGroupCallback): void;

Calls UpdateConsumerGroup.

Parameters
Name	Description
request	IUpdateConsumerGroupRequest UpdateConsumerGroupRequest message or plain object
callback	UpdateConsumerGroupCallback Node-style callback called with the error, if any, and ConsumerGroup

Returns
Type	Description
void

updateConsumerGroup(request)

public updateConsumerGroup(request: google.cloud.managedkafka.v1.IUpdateConsumerGroupRequest): Promise<google.cloud.managedkafka.v1.ConsumerGroup>;

Calls UpdateConsumerGroup.

Parameter
Name	Description
request	IUpdateConsumerGroupRequest UpdateConsumerGroupRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.ConsumerGroup>	Promise

updateTopic(request, callback)

public updateTopic(request: google.cloud.managedkafka.v1.IUpdateTopicRequest, callback: google.cloud.managedkafka.v1.ManagedKafka.UpdateTopicCallback): void;

Calls UpdateTopic.

Parameters
Name	Description
request	IUpdateTopicRequest UpdateTopicRequest message or plain object
callback	UpdateTopicCallback Node-style callback called with the error, if any, and Topic

Returns
Type	Description
void

updateTopic(request)

public updateTopic(request: google.cloud.managedkafka.v1.IUpdateTopicRequest): Promise<google.cloud.managedkafka.v1.Topic>;

Calls UpdateTopic.

Parameter
Name	Description
request	IUpdateTopicRequest UpdateTopicRequest message or plain object

Returns
Type	Description
Promise<google.cloud.managedkafka.v1.Topic>	Promise