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

Class GrpcManagedKafkaConnectStub

java.lang.Object

com.google.cloud.managedkafka.v1.stub.ManagedKafkaConnectStub

com.google.cloud.managedkafka.v1.stub.GrpcManagedKafkaConnectStub

All Implemented Interfaces:

BackgroundResource, AutoCloseable

@Generated("by gapic-generator-java")
public class GrpcManagedKafkaConnectStub
extends ManagedKafkaConnectStub

gRPC stub implementation for the ManagedKafkaConnect service API.

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long duration, TimeUnit unit)
final void	close()
static final GrpcManagedKafkaConnectStub	create(ClientContext clientContext)
static final GrpcManagedKafkaConnectStub	create(ClientContext clientContext, GrpcStubCallableFactory callableFactory)
static final GrpcManagedKafkaConnectStub	create(ManagedKafkaConnectStubSettings settings)
UnaryCallable<CreateConnectClusterRequest,Operation>	createConnectClusterCallable()
OperationCallable<CreateConnectClusterRequest,ConnectCluster,OperationMetadata>	createConnectClusterOperationCallable()
UnaryCallable<CreateConnectorRequest,Connector>	createConnectorCallable()
UnaryCallable<DeleteConnectClusterRequest,Operation>	deleteConnectClusterCallable()
OperationCallable<DeleteConnectClusterRequest,com.google.protobuf.Empty,OperationMetadata>	deleteConnectClusterOperationCallable()
UnaryCallable<DeleteConnectorRequest,com.google.protobuf.Empty>	deleteConnectorCallable()
UnaryCallable<GetConnectClusterRequest,ConnectCluster>	getConnectClusterCallable()
UnaryCallable<GetConnectorRequest,Connector>	getConnectorCallable()
UnaryCallable<GetLocationRequest,Location>	getLocationCallable()
GrpcOperationsStub	getOperationsStub()
boolean	isShutdown()
boolean	isTerminated()
UnaryCallable<ListConnectClustersRequest,ListConnectClustersResponse>	listConnectClustersCallable()
UnaryCallable<ListConnectClustersRequest,ManagedKafkaConnectClient.ListConnectClustersPagedResponse>	listConnectClustersPagedCallable()
UnaryCallable<ListConnectorsRequest,ListConnectorsResponse>	listConnectorsCallable()
UnaryCallable<ListConnectorsRequest,ManagedKafkaConnectClient.ListConnectorsPagedResponse>	listConnectorsPagedCallable()
UnaryCallable<ListLocationsRequest,ListLocationsResponse>	listLocationsCallable()
UnaryCallable<ListLocationsRequest,ManagedKafkaConnectClient.ListLocationsPagedResponse>	listLocationsPagedCallable()
UnaryCallable<PauseConnectorRequest,PauseConnectorResponse>	pauseConnectorCallable()
UnaryCallable<RestartConnectorRequest,RestartConnectorResponse>	restartConnectorCallable()
UnaryCallable<ResumeConnectorRequest,ResumeConnectorResponse>	resumeConnectorCallable()
void	shutdown()
void	shutdownNow()
UnaryCallable<StopConnectorRequest,StopConnectorResponse>	stopConnectorCallable()
UnaryCallable<UpdateConnectClusterRequest,Operation>	updateConnectClusterCallable()
OperationCallable<UpdateConnectClusterRequest,ConnectCluster,OperationMetadata>	updateConnectClusterOperationCallable()
UnaryCallable<UpdateConnectorRequest,Connector>	updateConnectorCallable()

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

getHttpJsonOperationsStub

Methods inherited from class java.lang.Object

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

Constructor Details

GrpcManagedKafkaConnectStub

protected GrpcManagedKafkaConnectStub(ManagedKafkaConnectStubSettings settings,
 ClientContext clientContext)
                               throws IOException

Constructs an instance of GrpcManagedKafkaConnectStub, 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

GrpcManagedKafkaConnectStub

protected GrpcManagedKafkaConnectStub(ManagedKafkaConnectStubSettings settings,
 ClientContext clientContext,
 GrpcStubCallableFactory callableFactory)
                               throws IOException

Constructs an instance of GrpcManagedKafkaConnectStub, 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 GrpcManagedKafkaConnectStub create(ManagedKafkaConnectStubSettings settings)
                                                throws IOException

Throws:

IOException

create

public static final GrpcManagedKafkaConnectStub create(ClientContext clientContext)
                                                throws IOException

Throws:

IOException

create

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

Throws:

IOException

getOperationsStub

public GrpcOperationsStub getOperationsStub()

Overrides:

getOperationsStub in class ManagedKafkaConnectStub

listConnectClustersCallable

public UnaryCallable<ListConnectClustersRequest,ListConnectClustersResponse> listConnectClustersCallable()

Overrides:

listConnectClustersCallable in class ManagedKafkaConnectStub

listConnectClustersPagedCallable

public UnaryCallable<ListConnectClustersRequest,ManagedKafkaConnectClient.ListConnectClustersPagedResponse> listConnectClustersPagedCallable()

Overrides:

listConnectClustersPagedCallable in class ManagedKafkaConnectStub

getConnectClusterCallable

public UnaryCallable<GetConnectClusterRequest,ConnectCluster> getConnectClusterCallable()

Overrides:

getConnectClusterCallable in class ManagedKafkaConnectStub

createConnectClusterCallable

public UnaryCallable<CreateConnectClusterRequest,Operation> createConnectClusterCallable()

Overrides:

createConnectClusterCallable in class ManagedKafkaConnectStub

createConnectClusterOperationCallable

public OperationCallable<CreateConnectClusterRequest,ConnectCluster,OperationMetadata> createConnectClusterOperationCallable()

Overrides:

createConnectClusterOperationCallable in class ManagedKafkaConnectStub

updateConnectClusterCallable

public UnaryCallable<UpdateConnectClusterRequest,Operation> updateConnectClusterCallable()

Overrides:

updateConnectClusterCallable in class ManagedKafkaConnectStub

updateConnectClusterOperationCallable

public OperationCallable<UpdateConnectClusterRequest,ConnectCluster,OperationMetadata> updateConnectClusterOperationCallable()

Overrides:

updateConnectClusterOperationCallable in class ManagedKafkaConnectStub

deleteConnectClusterCallable

public UnaryCallable<DeleteConnectClusterRequest,Operation> deleteConnectClusterCallable()

Overrides:

deleteConnectClusterCallable in class ManagedKafkaConnectStub

deleteConnectClusterOperationCallable

public OperationCallable<DeleteConnectClusterRequest,com.google.protobuf.Empty,OperationMetadata> deleteConnectClusterOperationCallable()

Overrides:

deleteConnectClusterOperationCallable in class ManagedKafkaConnectStub

listConnectorsCallable

public UnaryCallable<ListConnectorsRequest,ListConnectorsResponse> listConnectorsCallable()

Overrides:

listConnectorsCallable in class ManagedKafkaConnectStub

listConnectorsPagedCallable

public UnaryCallable<ListConnectorsRequest,ManagedKafkaConnectClient.ListConnectorsPagedResponse> listConnectorsPagedCallable()

Overrides:

listConnectorsPagedCallable in class ManagedKafkaConnectStub

getConnectorCallable

public UnaryCallable<GetConnectorRequest,Connector> getConnectorCallable()

Overrides:

getConnectorCallable in class ManagedKafkaConnectStub

createConnectorCallable

public UnaryCallable<CreateConnectorRequest,Connector> createConnectorCallable()

Overrides:

createConnectorCallable in class ManagedKafkaConnectStub

updateConnectorCallable

public UnaryCallable<UpdateConnectorRequest,Connector> updateConnectorCallable()

Overrides:

updateConnectorCallable in class ManagedKafkaConnectStub

deleteConnectorCallable

public UnaryCallable<DeleteConnectorRequest,com.google.protobuf.Empty> deleteConnectorCallable()

Overrides:

deleteConnectorCallable in class ManagedKafkaConnectStub

pauseConnectorCallable

public UnaryCallable<PauseConnectorRequest,PauseConnectorResponse> pauseConnectorCallable()

Overrides:

pauseConnectorCallable in class ManagedKafkaConnectStub

resumeConnectorCallable

public UnaryCallable<ResumeConnectorRequest,ResumeConnectorResponse> resumeConnectorCallable()

Overrides:

resumeConnectorCallable in class ManagedKafkaConnectStub

restartConnectorCallable

public UnaryCallable<RestartConnectorRequest,RestartConnectorResponse> restartConnectorCallable()

Overrides:

restartConnectorCallable in class ManagedKafkaConnectStub

stopConnectorCallable

public UnaryCallable<StopConnectorRequest,StopConnectorResponse> stopConnectorCallable()

Overrides:

stopConnectorCallable in class ManagedKafkaConnectStub

listLocationsCallable

public UnaryCallable<ListLocationsRequest,ListLocationsResponse> listLocationsCallable()

Overrides:

listLocationsCallable in class ManagedKafkaConnectStub

listLocationsPagedCallable

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

Overrides:

listLocationsPagedCallable in class ManagedKafkaConnectStub

getLocationCallable

public UnaryCallable<GetLocationRequest,Location> getLocationCallable()

Overrides:

getLocationCallable in class ManagedKafkaConnectStub

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in class ManagedKafkaConnectStub

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