Package com.google.cloud.managedkafka.v1.stub

Class GrpcManagedKafkaStub

java.lang.Object

com.google.cloud.managedkafka.v1.stub.ManagedKafkaStub

com.google.cloud.managedkafka.v1.stub.GrpcManagedKafkaStub

All Implemented Interfaces:

BackgroundResource, AutoCloseable

@Generated("by gapic-generator-java")
public class GrpcManagedKafkaStub
extends ManagedKafkaStub

gRPC stub implementation for the ManagedKafka service API.

This class is for advanced usage and reflects the underlying API directly.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GrpcManagedKafkaStub(ManagedKafkaStubSettings settings, ClientContext clientContext)	Constructs an instance of GrpcManagedKafkaStub, using the given settings.
protected	GrpcManagedKafkaStub(ManagedKafkaStubSettings settings, ClientContext clientContext, GrpcStubCallableFactory callableFactory)	Constructs an instance of GrpcManagedKafkaStub, using the given settings.

Method Summary

Modifier and Type	Method	Description
UnaryCallable<AddAclEntryRequest,AddAclEntryResponse>	addAclEntryCallable()
boolean	awaitTermination(long duration, TimeUnit unit)
final void	close()
static final GrpcManagedKafkaStub	create(ClientContext clientContext)
static final GrpcManagedKafkaStub	create(ClientContext clientContext, GrpcStubCallableFactory callableFactory)
static final GrpcManagedKafkaStub	create(ManagedKafkaStubSettings settings)
UnaryCallable<CreateAclRequest,Acl>	createAclCallable()
UnaryCallable<CreateClusterRequest,Operation>	createClusterCallable()
OperationCallable<CreateClusterRequest,Cluster,OperationMetadata>	createClusterOperationCallable()
UnaryCallable<CreateTopicRequest,Topic>	createTopicCallable()
UnaryCallable<DeleteAclRequest,com.google.protobuf.Empty>	deleteAclCallable()
UnaryCallable<DeleteClusterRequest,Operation>	deleteClusterCallable()
OperationCallable<DeleteClusterRequest,com.google.protobuf.Empty,OperationMetadata>	deleteClusterOperationCallable()
UnaryCallable<DeleteConsumerGroupRequest,com.google.protobuf.Empty>	deleteConsumerGroupCallable()
UnaryCallable<DeleteTopicRequest,com.google.protobuf.Empty>	deleteTopicCallable()
UnaryCallable<GetAclRequest,Acl>	getAclCallable()
UnaryCallable<GetClusterRequest,Cluster>	getClusterCallable()
UnaryCallable<GetConsumerGroupRequest,ConsumerGroup>	getConsumerGroupCallable()
UnaryCallable<GetLocationRequest,Location>	getLocationCallable()
GrpcOperationsStub	getOperationsStub()
UnaryCallable<GetTopicRequest,Topic>	getTopicCallable()
boolean	isShutdown()
boolean	isTerminated()
UnaryCallable<ListAclsRequest,ListAclsResponse>	listAclsCallable()
UnaryCallable<ListAclsRequest,ManagedKafkaClient.ListAclsPagedResponse>	listAclsPagedCallable()
UnaryCallable<ListClustersRequest,ListClustersResponse>	listClustersCallable()
UnaryCallable<ListClustersRequest,ManagedKafkaClient.ListClustersPagedResponse>	listClustersPagedCallable()
UnaryCallable<ListConsumerGroupsRequest,ListConsumerGroupsResponse>	listConsumerGroupsCallable()
UnaryCallable<ListConsumerGroupsRequest,ManagedKafkaClient.ListConsumerGroupsPagedResponse>	listConsumerGroupsPagedCallable()
UnaryCallable<ListLocationsRequest,ListLocationsResponse>	listLocationsCallable()
UnaryCallable<ListLocationsRequest,ManagedKafkaClient.ListLocationsPagedResponse>	listLocationsPagedCallable()
UnaryCallable<ListTopicsRequest,ListTopicsResponse>	listTopicsCallable()
UnaryCallable<ListTopicsRequest,ManagedKafkaClient.ListTopicsPagedResponse>	listTopicsPagedCallable()
UnaryCallable<RemoveAclEntryRequest,RemoveAclEntryResponse>	removeAclEntryCallable()
void	shutdown()
void	shutdownNow()
UnaryCallable<UpdateAclRequest,Acl>	updateAclCallable()
UnaryCallable<UpdateClusterRequest,Operation>	updateClusterCallable()
OperationCallable<UpdateClusterRequest,Cluster,OperationMetadata>	updateClusterOperationCallable()
UnaryCallable<UpdateConsumerGroupRequest,ConsumerGroup>	updateConsumerGroupCallable()
UnaryCallable<UpdateTopicRequest,Topic>	updateTopicCallable()

Methods inherited from class com.google.cloud.managedkafka.v1.stub.ManagedKafkaStub

getHttpJsonOperationsStub

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GrpcManagedKafkaStub

protected GrpcManagedKafkaStub(ManagedKafkaStubSettings settings,
 ClientContext clientContext)
                        throws IOException

Constructs an instance of GrpcManagedKafkaStub, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.

Throws:

IOException

GrpcManagedKafkaStub

protected GrpcManagedKafkaStub(ManagedKafkaStubSettings settings,
 ClientContext clientContext,
 GrpcStubCallableFactory callableFactory)
                        throws IOException

Constructs an instance of GrpcManagedKafkaStub, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.

Throws:

IOException

Method Details

create

public static final GrpcManagedKafkaStub create(ManagedKafkaStubSettings settings)
                                         throws IOException

Throws:

IOException

create

public static final GrpcManagedKafkaStub create(ClientContext clientContext)
                                         throws IOException

Throws:

IOException

create

public static final GrpcManagedKafkaStub create(ClientContext clientContext,
 GrpcStubCallableFactory callableFactory)
                                         throws IOException

Throws:

IOException

getOperationsStub

public GrpcOperationsStub getOperationsStub()

Overrides:

getOperationsStub in class ManagedKafkaStub

listClustersCallable

public UnaryCallable<ListClustersRequest,ListClustersResponse> listClustersCallable()

Overrides:

listClustersCallable in class ManagedKafkaStub

listClustersPagedCallable

public UnaryCallable<ListClustersRequest,ManagedKafkaClient.ListClustersPagedResponse> listClustersPagedCallable()

Overrides:

listClustersPagedCallable in class ManagedKafkaStub

getClusterCallable

public UnaryCallable<GetClusterRequest,Cluster> getClusterCallable()

Overrides:

getClusterCallable in class ManagedKafkaStub

createClusterCallable

public UnaryCallable<CreateClusterRequest,Operation> createClusterCallable()

Overrides:

createClusterCallable in class ManagedKafkaStub

createClusterOperationCallable

public OperationCallable<CreateClusterRequest,Cluster,OperationMetadata> createClusterOperationCallable()

Overrides:

createClusterOperationCallable in class ManagedKafkaStub

updateClusterCallable

public UnaryCallable<UpdateClusterRequest,Operation> updateClusterCallable()

Overrides:

updateClusterCallable in class ManagedKafkaStub

updateClusterOperationCallable

public OperationCallable<UpdateClusterRequest,Cluster,OperationMetadata> updateClusterOperationCallable()

Overrides:

updateClusterOperationCallable in class ManagedKafkaStub

deleteClusterCallable

public UnaryCallable<DeleteClusterRequest,Operation> deleteClusterCallable()

Overrides:

deleteClusterCallable in class ManagedKafkaStub

deleteClusterOperationCallable

public OperationCallable<DeleteClusterRequest,com.google.protobuf.Empty,OperationMetadata> deleteClusterOperationCallable()

Overrides:

deleteClusterOperationCallable in class ManagedKafkaStub

listTopicsCallable

public UnaryCallable<ListTopicsRequest,ListTopicsResponse> listTopicsCallable()

Overrides:

listTopicsCallable in class ManagedKafkaStub

listTopicsPagedCallable

public UnaryCallable<ListTopicsRequest,ManagedKafkaClient.ListTopicsPagedResponse> listTopicsPagedCallable()

Overrides:

listTopicsPagedCallable in class ManagedKafkaStub

getTopicCallable

public UnaryCallable<GetTopicRequest,Topic> getTopicCallable()

Overrides:

getTopicCallable in class ManagedKafkaStub

createTopicCallable

public UnaryCallable<CreateTopicRequest,Topic> createTopicCallable()

Overrides:

createTopicCallable in class ManagedKafkaStub

updateTopicCallable

public UnaryCallable<UpdateTopicRequest,Topic> updateTopicCallable()

Overrides:

updateTopicCallable in class ManagedKafkaStub

deleteTopicCallable

public UnaryCallable<DeleteTopicRequest,com.google.protobuf.Empty> deleteTopicCallable()

Overrides:

deleteTopicCallable in class ManagedKafkaStub

listConsumerGroupsCallable

public UnaryCallable<ListConsumerGroupsRequest,ListConsumerGroupsResponse> listConsumerGroupsCallable()

Overrides:

listConsumerGroupsCallable in class ManagedKafkaStub

listConsumerGroupsPagedCallable

public UnaryCallable<ListConsumerGroupsRequest,ManagedKafkaClient.ListConsumerGroupsPagedResponse> listConsumerGroupsPagedCallable()

Overrides:

listConsumerGroupsPagedCallable in class ManagedKafkaStub

getConsumerGroupCallable

public UnaryCallable<GetConsumerGroupRequest,ConsumerGroup> getConsumerGroupCallable()

Overrides:

getConsumerGroupCallable in class ManagedKafkaStub

updateConsumerGroupCallable

public UnaryCallable<UpdateConsumerGroupRequest,ConsumerGroup> updateConsumerGroupCallable()

Overrides:

updateConsumerGroupCallable in class ManagedKafkaStub

deleteConsumerGroupCallable

public UnaryCallable<DeleteConsumerGroupRequest,com.google.protobuf.Empty> deleteConsumerGroupCallable()

Overrides:

deleteConsumerGroupCallable in class ManagedKafkaStub

listAclsCallable

public UnaryCallable<ListAclsRequest,ListAclsResponse> listAclsCallable()

Overrides:

listAclsCallable in class ManagedKafkaStub

listAclsPagedCallable

public UnaryCallable<ListAclsRequest,ManagedKafkaClient.ListAclsPagedResponse> listAclsPagedCallable()

Overrides:

listAclsPagedCallable in class ManagedKafkaStub

getAclCallable

public UnaryCallable<GetAclRequest,Acl> getAclCallable()

Overrides:

getAclCallable in class ManagedKafkaStub

createAclCallable

public UnaryCallable<CreateAclRequest,Acl> createAclCallable()

Overrides:

createAclCallable in class ManagedKafkaStub

updateAclCallable

public UnaryCallable<UpdateAclRequest,Acl> updateAclCallable()

Overrides:

updateAclCallable in class ManagedKafkaStub

deleteAclCallable

public UnaryCallable<DeleteAclRequest,com.google.protobuf.Empty> deleteAclCallable()

Overrides:

deleteAclCallable in class ManagedKafkaStub

addAclEntryCallable

public UnaryCallable<AddAclEntryRequest,AddAclEntryResponse> addAclEntryCallable()

Overrides:

addAclEntryCallable in class ManagedKafkaStub

removeAclEntryCallable

public UnaryCallable<RemoveAclEntryRequest,RemoveAclEntryResponse> removeAclEntryCallable()

Overrides:

removeAclEntryCallable in class ManagedKafkaStub

listLocationsCallable

public UnaryCallable<ListLocationsRequest,ListLocationsResponse> listLocationsCallable()

Overrides:

listLocationsCallable in class ManagedKafkaStub

listLocationsPagedCallable

public UnaryCallable<ListLocationsRequest,ManagedKafkaClient.ListLocationsPagedResponse> listLocationsPagedCallable()

Overrides:

listLocationsPagedCallable in class ManagedKafkaStub

getLocationCallable

public UnaryCallable<GetLocationRequest,Location> getLocationCallable()

Overrides:

getLocationCallable in class ManagedKafkaStub

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in class ManagedKafkaStub

shutdown

public void shutdown()

isShutdown

public boolean isShutdown()

isTerminated

public boolean isTerminated()

shutdownNow

public void shutdownNow()

awaitTermination

public boolean awaitTermination(long duration,
 TimeUnit unit)
                         throws InterruptedException

Throws:

InterruptedException