public static final class DatastreamGrpc.DatastreamFutureStub extends AbstractFutureStub.DatastreamFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service Datastream.
Datastream service
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
DatastreamGrpc.DatastreamFutureStub
Inherited Members
io.grpc.stub.AbstractFutureStub.newStub(io.grpc.stub.AbstractStub.StubFactory,io.grpc.Channel)
io.grpc.stub.AbstractFutureStub.newStub(io.grpc.stub.AbstractStub.StubFactory,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.withOption(io.grpc.CallOptions.Key,T)
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.getCallOptions()
io.grpc.stub.AbstractStub.getChannel()
io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)
io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)
io.grpc.stub.AbstractStub.withCompression(java.lang.String)
io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)
io.grpc.stub.AbstractStub.withDeadlineAfter(java.time.Duration)
io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)
io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)
io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)
io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)
io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)
io.grpc.stub.AbstractStub.withOnReadyThreshold(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
build(Channel channel, CallOptions callOptions)
protected DatastreamGrpc.DatastreamFutureStub build(Channel channel, CallOptions callOptions)
| Parameters |
| Name |
Description |
channel |
io.grpc.Channel
|
callOptions |
io.grpc.CallOptions
|
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
createConnectionProfile(CreateConnectionProfileRequest request)
public ListenableFuture createConnectionProfile(CreateConnectionProfileRequest request)
Use this method to create a connection profile in a project and location.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
createPrivateConnection(CreatePrivateConnectionRequest request)
public ListenableFuture createPrivateConnection(CreatePrivateConnectionRequest request)
Use this method to create a private connectivity configuration.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
createRoute(CreateRouteRequest request)
public ListenableFuture createRoute(CreateRouteRequest request)
Use this method to create a route for a private connectivity configuration
in a project and location.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
createStream(CreateStreamRequest request)
public ListenableFuture createStream(CreateStreamRequest request)
Use this method to create a stream.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
deleteConnectionProfile(DeleteConnectionProfileRequest request)
public ListenableFuture deleteConnectionProfile(DeleteConnectionProfileRequest request)
Use this method to delete a connection profile.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
deletePrivateConnection(DeletePrivateConnectionRequest request)
public ListenableFuture deletePrivateConnection(DeletePrivateConnectionRequest request)
Use this method to delete a private connectivity configuration.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
deleteRoute(DeleteRouteRequest request)
public ListenableFuture deleteRoute(DeleteRouteRequest request)
Use this method to delete a route.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
deleteStream(DeleteStreamRequest request)
public ListenableFuture deleteStream(DeleteStreamRequest request)
Use this method to delete a stream.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
discoverConnectionProfile(DiscoverConnectionProfileRequest request)
public ListenableFuture discoverConnectionProfile(DiscoverConnectionProfileRequest request)
Use this method to discover a connection profile.
The discover API call exposes the data objects and metadata belonging to
the profile. Typically, a request returns children data objects of a
parent data object that's optionally supplied in the request.
fetchStaticIps(FetchStaticIpsRequest request)
public ListenableFuture fetchStaticIps(FetchStaticIpsRequest request)
The FetchStaticIps API call exposes the static IP addresses used by
Datastream.
getConnectionProfile(GetConnectionProfileRequest request)
public ListenableFuture getConnectionProfile(GetConnectionProfileRequest request)
Use this method to get details about a connection profile.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<ConnectionProfile> |
|
getPrivateConnection(GetPrivateConnectionRequest request)
public ListenableFuture getPrivateConnection(GetPrivateConnectionRequest request)
Use this method to get details about a private connectivity configuration.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<PrivateConnection> |
|
getRoute(GetRouteRequest request)
public ListenableFuture getRoute(GetRouteRequest request)
Use this method to get details about a route.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Route> |
|
getStream(GetStreamRequest request)
public ListenableFuture getStream(GetStreamRequest request)
Use this method to get details about a stream.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Stream> |
|
getStreamObject(GetStreamObjectRequest request)
public ListenableFuture getStreamObject(GetStreamObjectRequest request)
Use this method to get details about a stream object.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<StreamObject> |
|
listConnectionProfiles(ListConnectionProfilesRequest request)
public ListenableFuture listConnectionProfiles(ListConnectionProfilesRequest request)
Use this method to list connection profiles created in a project and
location.
listPrivateConnections(ListPrivateConnectionsRequest request)
public ListenableFuture listPrivateConnections(ListPrivateConnectionsRequest request)
Use this method to list private connectivity configurations in a project
and location.
listRoutes(ListRoutesRequest request)
public ListenableFuture listRoutes(ListRoutesRequest request)
Use this method to list routes created for a private connectivity
configuration in a project and location.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<ListRoutesResponse> |
|
listStreamObjects(ListStreamObjectsRequest request)
public ListenableFuture listStreamObjects(ListStreamObjectsRequest request)
Use this method to list the objects of a specific stream.
listStreams(ListStreamsRequest request)
public ListenableFuture listStreams(ListStreamsRequest request)
Use this method to list streams in a project and location.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<ListStreamsResponse> |
|
lookupStreamObject(LookupStreamObjectRequest request)
public ListenableFuture lookupStreamObject(LookupStreamObjectRequest request)
Use this method to look up a stream object by its source object identifier.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<StreamObject> |
|
runStream(RunStreamRequest request)
public ListenableFuture runStream(RunStreamRequest request)
Use this method to start, resume or recover a stream with a non default CDC
strategy.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
startBackfillJob(StartBackfillJobRequest request)
public ListenableFuture startBackfillJob(StartBackfillJobRequest request)
Use this method to start a backfill job for the specified stream object.
stopBackfillJob(StopBackfillJobRequest request)
public ListenableFuture stopBackfillJob(StopBackfillJobRequest request)
Use this method to stop a backfill job for the specified stream object.
updateConnectionProfile(UpdateConnectionProfileRequest request)
public ListenableFuture updateConnectionProfile(UpdateConnectionProfileRequest request)
Use this method to update the parameters of a connection profile.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
updateStream(UpdateStreamRequest request)
public ListenableFuture updateStream(UpdateStreamRequest request)
Use this method to update the configuration of a stream.
| Returns |
| Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
