Class DatastreamGrpc.DatastreamFutureStub (1.28.0)
1.86.0 (latest)
1.84.0
1.82.0
1.81.0
1.80.0
1.79.0
1.77.0
1.75.0
1.74.0
1.73.0
1.72.0
1.71.0
1.69.0
1.67.0
1.66.0
1.63.0
1.62.0
1.61.0
1.59.0
1.58.0
1.57.0
1.56.0
1.55.0
1.54.0
1.53.0
1.52.0
1.51.0
1.50.0
1.48.0
1.47.0
1.46.0
1.45.0
1.44.0
1.43.0
1.42.0
1.41.0
1.40.0
1.39.0
1.38.0
1.36.0
1.35.0
1.34.0
1.33.0
1.32.0
1.31.0
1.30.0
1.29.0
1.28.0
1.27.0
1.26.0
1.23.0
1.22.0
1.21.0
1.20.0
1.19.0
1.18.0
1.17.0
1.16.0
1.15.0
1.14.0
1.13.0
1.12.0
1.11.0
1.10.0
1.8.0
1.7.0
1.6.0
1.5.0
1.4.0
1.3.0
1.2.2
1.1.1
1.0.0
0.4.2
public static final class DatastreamGrpc . DatastreamFutureStub extends AbstractFutureStub<DatastreamGrpc . 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.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractFutureStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,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(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.withWaitForReady()
Methods
build(Channel channel, CallOptions callOptions)
protected DatastreamGrpc . DatastreamFutureStub build ( Channel channel , CallOptions callOptions )
Parameters
Name Description
channelio.grpc.Channel
callOptionsio.grpc.CallOptions
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
createConnectionProfile(CreateConnectionProfileRequest request)
public ListenableFuture<Operation> 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<Operation> 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<Operation> createRoute ( CreateRouteRequest request )
Use this method to create a route for a private connectivity in a project
and location.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
createStream(CreateStreamRequest request)
public ListenableFuture<Operation> 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<Operation> 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<Operation> 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<Operation> 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<Operation> 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<DiscoverConnectionProfileResponse> 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 under a
parent data object that's optionally supplied in the request.
fetchErrors(FetchErrorsRequest request)
public ListenableFuture<Operation> fetchErrors ( FetchErrorsRequest request )
Use this method to fetch any errors associated with a stream.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
fetchStaticIps(FetchStaticIpsRequest request)
public ListenableFuture<FetchStaticIpsResponse> fetchStaticIps ( FetchStaticIpsRequest request )
The FetchStaticIps API call exposes the static ips used by Datastream.
Typically, a request returns children data objects under
a parent data object that's optionally supplied in the request.
getConnectionProfile(GetConnectionProfileRequest request)
public ListenableFuture<ConnectionProfile> 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<PrivateConnection> 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<Route> 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<Stream> getStream ( GetStreamRequest request )
Use this method to get details about a stream.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Stream >
listConnectionProfiles(ListConnectionProfilesRequest request)
public ListenableFuture<ListConnectionProfilesResponse> listConnectionProfiles ( ListConnectionProfilesRequest request )
Use this method to list connection profiles created in a project and
location.
listPrivateConnections(ListPrivateConnectionsRequest request)
public ListenableFuture<ListPrivateConnectionsResponse> listPrivateConnections ( ListPrivateConnectionsRequest request )
Use this method to list private connectivity configurations in a project
and location.
listRoutes(ListRoutesRequest request)
public ListenableFuture<ListRoutesResponse> listRoutes ( ListRoutesRequest request )
Use this method to list routes created for a private connectivity in a
project and location.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <ListRoutesResponse >
listStreams(ListStreamsRequest request)
public ListenableFuture<ListStreamsResponse> listStreams ( ListStreamsRequest request )
Use this method to list streams in a project and location.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <ListStreamsResponse >
updateConnectionProfile(UpdateConnectionProfileRequest request)
public ListenableFuture<Operation> 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<Operation> updateStream ( UpdateStreamRequest request )
Use this method to update the configuration of a stream.
Returns
Type Description
com.google.common.util.concurrent.ListenableFuture <Operation >
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2026-03-14 UTC.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2026-03-14 UTC."],[],[]]
