Package com.google.cloud.datastream.v1.stub

Class GrpcDatastreamStub

java.lang.Object

com.google.cloud.datastream.v1.stub.DatastreamStub

com.google.cloud.datastream.v1.stub.GrpcDatastreamStub

All Implemented Interfaces:

com.google.api.gax.core.BackgroundResource, AutoCloseable

@Generated("by gapic-generator-java")
public class GrpcDatastreamStub
extends DatastreamStub

gRPC stub implementation for the Datastream service API.

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

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GrpcDatastreamStub(DatastreamStubSettings settings, com.google.api.gax.rpc.ClientContext clientContext)	Constructs an instance of GrpcDatastreamStub, using the given settings.
protected	GrpcDatastreamStub(DatastreamStubSettings settings, com.google.api.gax.rpc.ClientContext clientContext, com.google.api.gax.grpc.GrpcStubCallableFactory callableFactory)	Constructs an instance of GrpcDatastreamStub, using the given settings.

Method Summary

Modifier and Type	Method	Description
boolean	awaitTermination(long duration, TimeUnit unit)
void	close()
static GrpcDatastreamStub	create(com.google.api.gax.rpc.ClientContext clientContext)
static GrpcDatastreamStub	create(com.google.api.gax.rpc.ClientContext clientContext, com.google.api.gax.grpc.GrpcStubCallableFactory callableFactory)
static GrpcDatastreamStub	create(DatastreamStubSettings settings)
com.google.api.gax.rpc.UnaryCallable<CreateConnectionProfileRequest,com.google.longrunning.Operation>	createConnectionProfileCallable()
com.google.api.gax.rpc.OperationCallable<CreateConnectionProfileRequest,ConnectionProfile,OperationMetadata>	createConnectionProfileOperationCallable()
com.google.api.gax.rpc.UnaryCallable<CreatePrivateConnectionRequest,com.google.longrunning.Operation>	createPrivateConnectionCallable()
com.google.api.gax.rpc.OperationCallable<CreatePrivateConnectionRequest,PrivateConnection,OperationMetadata>	createPrivateConnectionOperationCallable()
com.google.api.gax.rpc.UnaryCallable<CreateRouteRequest,com.google.longrunning.Operation>	createRouteCallable()
com.google.api.gax.rpc.OperationCallable<CreateRouteRequest,Route,OperationMetadata>	createRouteOperationCallable()
com.google.api.gax.rpc.UnaryCallable<CreateStreamRequest,com.google.longrunning.Operation>	createStreamCallable()
com.google.api.gax.rpc.OperationCallable<CreateStreamRequest,Stream,OperationMetadata>	createStreamOperationCallable()
com.google.api.gax.rpc.UnaryCallable<DeleteConnectionProfileRequest,com.google.longrunning.Operation>	deleteConnectionProfileCallable()
com.google.api.gax.rpc.OperationCallable<DeleteConnectionProfileRequest,com.google.protobuf.Empty,OperationMetadata>	deleteConnectionProfileOperationCallable()
com.google.api.gax.rpc.UnaryCallable<DeletePrivateConnectionRequest,com.google.longrunning.Operation>	deletePrivateConnectionCallable()
com.google.api.gax.rpc.OperationCallable<DeletePrivateConnectionRequest,com.google.protobuf.Empty,OperationMetadata>	deletePrivateConnectionOperationCallable()
com.google.api.gax.rpc.UnaryCallable<DeleteRouteRequest,com.google.longrunning.Operation>	deleteRouteCallable()
com.google.api.gax.rpc.OperationCallable<DeleteRouteRequest,com.google.protobuf.Empty,OperationMetadata>	deleteRouteOperationCallable()
com.google.api.gax.rpc.UnaryCallable<DeleteStreamRequest,com.google.longrunning.Operation>	deleteStreamCallable()
com.google.api.gax.rpc.OperationCallable<DeleteStreamRequest,com.google.protobuf.Empty,OperationMetadata>	deleteStreamOperationCallable()
com.google.api.gax.rpc.UnaryCallable<DiscoverConnectionProfileRequest,DiscoverConnectionProfileResponse>	discoverConnectionProfileCallable()
com.google.api.gax.rpc.UnaryCallable<FetchStaticIpsRequest,FetchStaticIpsResponse>	fetchStaticIpsCallable()
com.google.api.gax.rpc.UnaryCallable<FetchStaticIpsRequest,DatastreamClient.FetchStaticIpsPagedResponse>	fetchStaticIpsPagedCallable()
com.google.api.gax.rpc.UnaryCallable<GetConnectionProfileRequest,ConnectionProfile>	getConnectionProfileCallable()
com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.GetLocationRequest,com.google.cloud.location.Location>	getLocationCallable()
com.google.longrunning.stub.GrpcOperationsStub	getOperationsStub()
com.google.api.gax.rpc.UnaryCallable<GetPrivateConnectionRequest,PrivateConnection>	getPrivateConnectionCallable()
com.google.api.gax.rpc.UnaryCallable<GetRouteRequest,Route>	getRouteCallable()
com.google.api.gax.rpc.UnaryCallable<GetStreamRequest,Stream>	getStreamCallable()
com.google.api.gax.rpc.UnaryCallable<GetStreamObjectRequest,StreamObject>	getStreamObjectCallable()
boolean	isShutdown()
boolean	isTerminated()
com.google.api.gax.rpc.UnaryCallable<ListConnectionProfilesRequest,ListConnectionProfilesResponse>	listConnectionProfilesCallable()
com.google.api.gax.rpc.UnaryCallable<ListConnectionProfilesRequest,DatastreamClient.ListConnectionProfilesPagedResponse>	listConnectionProfilesPagedCallable()
com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,com.google.cloud.location.ListLocationsResponse>	listLocationsCallable()
com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,DatastreamClient.ListLocationsPagedResponse>	listLocationsPagedCallable()
com.google.api.gax.rpc.UnaryCallable<ListPrivateConnectionsRequest,ListPrivateConnectionsResponse>	listPrivateConnectionsCallable()
com.google.api.gax.rpc.UnaryCallable<ListPrivateConnectionsRequest,DatastreamClient.ListPrivateConnectionsPagedResponse>	listPrivateConnectionsPagedCallable()
com.google.api.gax.rpc.UnaryCallable<ListRoutesRequest,ListRoutesResponse>	listRoutesCallable()
com.google.api.gax.rpc.UnaryCallable<ListRoutesRequest,DatastreamClient.ListRoutesPagedResponse>	listRoutesPagedCallable()
com.google.api.gax.rpc.UnaryCallable<ListStreamObjectsRequest,ListStreamObjectsResponse>	listStreamObjectsCallable()
com.google.api.gax.rpc.UnaryCallable<ListStreamObjectsRequest,DatastreamClient.ListStreamObjectsPagedResponse>	listStreamObjectsPagedCallable()
com.google.api.gax.rpc.UnaryCallable<ListStreamsRequest,ListStreamsResponse>	listStreamsCallable()
com.google.api.gax.rpc.UnaryCallable<ListStreamsRequest,DatastreamClient.ListStreamsPagedResponse>	listStreamsPagedCallable()
com.google.api.gax.rpc.UnaryCallable<LookupStreamObjectRequest,StreamObject>	lookupStreamObjectCallable()
void	shutdown()
void	shutdownNow()
com.google.api.gax.rpc.UnaryCallable<StartBackfillJobRequest,StartBackfillJobResponse>	startBackfillJobCallable()
com.google.api.gax.rpc.UnaryCallable<StopBackfillJobRequest,StopBackfillJobResponse>	stopBackfillJobCallable()
com.google.api.gax.rpc.UnaryCallable<UpdateConnectionProfileRequest,com.google.longrunning.Operation>	updateConnectionProfileCallable()
com.google.api.gax.rpc.OperationCallable<UpdateConnectionProfileRequest,ConnectionProfile,OperationMetadata>	updateConnectionProfileOperationCallable()
com.google.api.gax.rpc.UnaryCallable<UpdateStreamRequest,com.google.longrunning.Operation>	updateStreamCallable()
com.google.api.gax.rpc.OperationCallable<UpdateStreamRequest,Stream,OperationMetadata>	updateStreamOperationCallable()

Methods inherited from class com.google.cloud.datastream.v1.stub.DatastreamStub

getHttpJsonOperationsStub

Methods inherited from class java.lang.Object

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

Constructor Detail

GrpcDatastreamStub

protected GrpcDatastreamStub(DatastreamStubSettings settings,
                             com.google.api.gax.rpc.ClientContext clientContext)
                      throws IOException

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

GrpcDatastreamStub

protected GrpcDatastreamStub(DatastreamStubSettings settings,
                             com.google.api.gax.rpc.ClientContext clientContext,
                             com.google.api.gax.grpc.GrpcStubCallableFactory callableFactory)
                      throws IOException

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

create

public static final GrpcDatastreamStub create(DatastreamStubSettings settings)
                                       throws IOException

Throws:

IOException

create

public static final GrpcDatastreamStub create(com.google.api.gax.rpc.ClientContext clientContext)
                                       throws IOException

Throws:

IOException

create

public static final GrpcDatastreamStub create(com.google.api.gax.rpc.ClientContext clientContext,
                                              com.google.api.gax.grpc.GrpcStubCallableFactory callableFactory)
                                       throws IOException

Throws:

IOException

getOperationsStub

public com.google.longrunning.stub.GrpcOperationsStub getOperationsStub()

Overrides:

getOperationsStub in class DatastreamStub

listConnectionProfilesCallable

public com.google.api.gax.rpc.UnaryCallable<ListConnectionProfilesRequest,ListConnectionProfilesResponse> listConnectionProfilesCallable()

Overrides:

listConnectionProfilesCallable in class DatastreamStub

listConnectionProfilesPagedCallable

public com.google.api.gax.rpc.UnaryCallable<ListConnectionProfilesRequest,DatastreamClient.ListConnectionProfilesPagedResponse> listConnectionProfilesPagedCallable()

Overrides:

listConnectionProfilesPagedCallable in class DatastreamStub

getConnectionProfileCallable

public com.google.api.gax.rpc.UnaryCallable<GetConnectionProfileRequest,ConnectionProfile> getConnectionProfileCallable()

Overrides:

getConnectionProfileCallable in class DatastreamStub

createConnectionProfileCallable

public com.google.api.gax.rpc.UnaryCallable<CreateConnectionProfileRequest,com.google.longrunning.Operation> createConnectionProfileCallable()

Overrides:

createConnectionProfileCallable in class DatastreamStub

createConnectionProfileOperationCallable

public com.google.api.gax.rpc.OperationCallable<CreateConnectionProfileRequest,ConnectionProfile,OperationMetadata> createConnectionProfileOperationCallable()

Overrides:

createConnectionProfileOperationCallable in class DatastreamStub

updateConnectionProfileCallable

public com.google.api.gax.rpc.UnaryCallable<UpdateConnectionProfileRequest,com.google.longrunning.Operation> updateConnectionProfileCallable()

Overrides:

updateConnectionProfileCallable in class DatastreamStub

updateConnectionProfileOperationCallable

public com.google.api.gax.rpc.OperationCallable<UpdateConnectionProfileRequest,ConnectionProfile,OperationMetadata> updateConnectionProfileOperationCallable()

Overrides:

updateConnectionProfileOperationCallable in class DatastreamStub

deleteConnectionProfileCallable

public com.google.api.gax.rpc.UnaryCallable<DeleteConnectionProfileRequest,com.google.longrunning.Operation> deleteConnectionProfileCallable()

Overrides:

deleteConnectionProfileCallable in class DatastreamStub

deleteConnectionProfileOperationCallable

public com.google.api.gax.rpc.OperationCallable<DeleteConnectionProfileRequest,com.google.protobuf.Empty,OperationMetadata> deleteConnectionProfileOperationCallable()

Overrides:

deleteConnectionProfileOperationCallable in class DatastreamStub

discoverConnectionProfileCallable

public com.google.api.gax.rpc.UnaryCallable<DiscoverConnectionProfileRequest,DiscoverConnectionProfileResponse> discoverConnectionProfileCallable()

Overrides:

discoverConnectionProfileCallable in class DatastreamStub

listStreamsCallable

public com.google.api.gax.rpc.UnaryCallable<ListStreamsRequest,ListStreamsResponse> listStreamsCallable()

Overrides:

listStreamsCallable in class DatastreamStub

listStreamsPagedCallable

public com.google.api.gax.rpc.UnaryCallable<ListStreamsRequest,DatastreamClient.ListStreamsPagedResponse> listStreamsPagedCallable()

Overrides:

listStreamsPagedCallable in class DatastreamStub

getStreamCallable

public com.google.api.gax.rpc.UnaryCallable<GetStreamRequest,Stream> getStreamCallable()

Overrides:

getStreamCallable in class DatastreamStub

createStreamCallable

public com.google.api.gax.rpc.UnaryCallable<CreateStreamRequest,com.google.longrunning.Operation> createStreamCallable()

Overrides:

createStreamCallable in class DatastreamStub

createStreamOperationCallable

public com.google.api.gax.rpc.OperationCallable<CreateStreamRequest,Stream,OperationMetadata> createStreamOperationCallable()

Overrides:

createStreamOperationCallable in class DatastreamStub

updateStreamCallable

public com.google.api.gax.rpc.UnaryCallable<UpdateStreamRequest,com.google.longrunning.Operation> updateStreamCallable()

Overrides:

updateStreamCallable in class DatastreamStub

updateStreamOperationCallable

public com.google.api.gax.rpc.OperationCallable<UpdateStreamRequest,Stream,OperationMetadata> updateStreamOperationCallable()

Overrides:

updateStreamOperationCallable in class DatastreamStub

deleteStreamCallable

public com.google.api.gax.rpc.UnaryCallable<DeleteStreamRequest,com.google.longrunning.Operation> deleteStreamCallable()

Overrides:

deleteStreamCallable in class DatastreamStub

deleteStreamOperationCallable

public com.google.api.gax.rpc.OperationCallable<DeleteStreamRequest,com.google.protobuf.Empty,OperationMetadata> deleteStreamOperationCallable()

Overrides:

deleteStreamOperationCallable in class DatastreamStub

getStreamObjectCallable

public com.google.api.gax.rpc.UnaryCallable<GetStreamObjectRequest,StreamObject> getStreamObjectCallable()

Overrides:

getStreamObjectCallable in class DatastreamStub

lookupStreamObjectCallable

public com.google.api.gax.rpc.UnaryCallable<LookupStreamObjectRequest,StreamObject> lookupStreamObjectCallable()

Overrides:

lookupStreamObjectCallable in class DatastreamStub

listStreamObjectsCallable

public com.google.api.gax.rpc.UnaryCallable<ListStreamObjectsRequest,ListStreamObjectsResponse> listStreamObjectsCallable()

Overrides:

listStreamObjectsCallable in class DatastreamStub

listStreamObjectsPagedCallable

public com.google.api.gax.rpc.UnaryCallable<ListStreamObjectsRequest,DatastreamClient.ListStreamObjectsPagedResponse> listStreamObjectsPagedCallable()

Overrides:

listStreamObjectsPagedCallable in class DatastreamStub

startBackfillJobCallable

public com.google.api.gax.rpc.UnaryCallable<StartBackfillJobRequest,StartBackfillJobResponse> startBackfillJobCallable()

Overrides:

startBackfillJobCallable in class DatastreamStub

stopBackfillJobCallable

public com.google.api.gax.rpc.UnaryCallable<StopBackfillJobRequest,StopBackfillJobResponse> stopBackfillJobCallable()

Overrides:

stopBackfillJobCallable in class DatastreamStub

fetchStaticIpsCallable

public com.google.api.gax.rpc.UnaryCallable<FetchStaticIpsRequest,FetchStaticIpsResponse> fetchStaticIpsCallable()

Overrides:

fetchStaticIpsCallable in class DatastreamStub

fetchStaticIpsPagedCallable

public com.google.api.gax.rpc.UnaryCallable<FetchStaticIpsRequest,DatastreamClient.FetchStaticIpsPagedResponse> fetchStaticIpsPagedCallable()

Overrides:

fetchStaticIpsPagedCallable in class DatastreamStub

createPrivateConnectionCallable

public com.google.api.gax.rpc.UnaryCallable<CreatePrivateConnectionRequest,com.google.longrunning.Operation> createPrivateConnectionCallable()

Overrides:

createPrivateConnectionCallable in class DatastreamStub

createPrivateConnectionOperationCallable

public com.google.api.gax.rpc.OperationCallable<CreatePrivateConnectionRequest,PrivateConnection,OperationMetadata> createPrivateConnectionOperationCallable()

Overrides:

createPrivateConnectionOperationCallable in class DatastreamStub

getPrivateConnectionCallable

public com.google.api.gax.rpc.UnaryCallable<GetPrivateConnectionRequest,PrivateConnection> getPrivateConnectionCallable()

Overrides:

getPrivateConnectionCallable in class DatastreamStub

listPrivateConnectionsCallable

public com.google.api.gax.rpc.UnaryCallable<ListPrivateConnectionsRequest,ListPrivateConnectionsResponse> listPrivateConnectionsCallable()

Overrides:

listPrivateConnectionsCallable in class DatastreamStub

listPrivateConnectionsPagedCallable

public com.google.api.gax.rpc.UnaryCallable<ListPrivateConnectionsRequest,DatastreamClient.ListPrivateConnectionsPagedResponse> listPrivateConnectionsPagedCallable()

Overrides:

listPrivateConnectionsPagedCallable in class DatastreamStub

deletePrivateConnectionCallable

public com.google.api.gax.rpc.UnaryCallable<DeletePrivateConnectionRequest,com.google.longrunning.Operation> deletePrivateConnectionCallable()

Overrides:

deletePrivateConnectionCallable in class DatastreamStub

deletePrivateConnectionOperationCallable

public com.google.api.gax.rpc.OperationCallable<DeletePrivateConnectionRequest,com.google.protobuf.Empty,OperationMetadata> deletePrivateConnectionOperationCallable()

Overrides:

deletePrivateConnectionOperationCallable in class DatastreamStub

createRouteCallable

public com.google.api.gax.rpc.UnaryCallable<CreateRouteRequest,com.google.longrunning.Operation> createRouteCallable()

Overrides:

createRouteCallable in class DatastreamStub

createRouteOperationCallable

public com.google.api.gax.rpc.OperationCallable<CreateRouteRequest,Route,OperationMetadata> createRouteOperationCallable()

Overrides:

createRouteOperationCallable in class DatastreamStub

getRouteCallable

public com.google.api.gax.rpc.UnaryCallable<GetRouteRequest,Route> getRouteCallable()

Overrides:

getRouteCallable in class DatastreamStub

listRoutesCallable

public com.google.api.gax.rpc.UnaryCallable<ListRoutesRequest,ListRoutesResponse> listRoutesCallable()

Overrides:

listRoutesCallable in class DatastreamStub

listRoutesPagedCallable

public com.google.api.gax.rpc.UnaryCallable<ListRoutesRequest,DatastreamClient.ListRoutesPagedResponse> listRoutesPagedCallable()

Overrides:

listRoutesPagedCallable in class DatastreamStub

deleteRouteCallable

public com.google.api.gax.rpc.UnaryCallable<DeleteRouteRequest,com.google.longrunning.Operation> deleteRouteCallable()

Overrides:

deleteRouteCallable in class DatastreamStub

deleteRouteOperationCallable

public com.google.api.gax.rpc.OperationCallable<DeleteRouteRequest,com.google.protobuf.Empty,OperationMetadata> deleteRouteOperationCallable()

Overrides:

deleteRouteOperationCallable in class DatastreamStub

listLocationsCallable

public com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,com.google.cloud.location.ListLocationsResponse> listLocationsCallable()

Overrides:

listLocationsCallable in class DatastreamStub

listLocationsPagedCallable

public com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.ListLocationsRequest,DatastreamClient.ListLocationsPagedResponse> listLocationsPagedCallable()

Overrides:

listLocationsPagedCallable in class DatastreamStub

getLocationCallable

public com.google.api.gax.rpc.UnaryCallable<com.google.cloud.location.GetLocationRequest,com.google.cloud.location.Location> getLocationCallable()

Overrides:

getLocationCallable in class DatastreamStub

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in class DatastreamStub

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