public static final class DataFusionGrpc.DataFusionFutureStub extends AbstractFutureStub<DataFusionGrpc.DataFusionFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service DataFusion.
Service for creating and managing Data Fusion instances.
Data Fusion enables ETL developers to build code-free, data integration
pipelines via a point-and-click UI.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
DataFusionGrpc.DataFusionFutureStub
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
addDnsPeering(AddDnsPeeringRequest request)
public ListenableFuture<AddDnsPeeringResponse> addDnsPeering(AddDnsPeeringRequest request)
Add DNS peering on the given resource.
build(Channel channel, CallOptions callOptions)
protected DataFusionGrpc.DataFusionFutureStub 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)
createInstance(CreateInstanceRequest request)
public ListenableFuture<Operation> createInstance(CreateInstanceRequest request)
Creates a new Data Fusion instance in the specified project and location.
Returns |
---|
Type | Description |
com.google.common.util.concurrent.ListenableFuture<Operation> | |
deleteInstance(DeleteInstanceRequest request)
public ListenableFuture<Operation> deleteInstance(DeleteInstanceRequest request)
Deletes a single Data Fusion instance.
Returns |
---|
Type | Description |
com.google.common.util.concurrent.ListenableFuture<Operation> | |
getInstance(GetInstanceRequest request)
public ListenableFuture<Instance> getInstance(GetInstanceRequest request)
Gets details of a single Data Fusion instance.
Returns |
---|
Type | Description |
com.google.common.util.concurrent.ListenableFuture<Instance> | |
listAvailableVersions(ListAvailableVersionsRequest request)
public ListenableFuture<ListAvailableVersionsResponse> listAvailableVersions(ListAvailableVersionsRequest request)
Lists possible versions for Data Fusion instances in the specified project
and location.
listDnsPeerings(ListDnsPeeringsRequest request)
public ListenableFuture<ListDnsPeeringsResponse> listDnsPeerings(ListDnsPeeringsRequest request)
List DNS peering for a given resource.
listInstances(ListInstancesRequest request)
public ListenableFuture<ListInstancesResponse> listInstances(ListInstancesRequest request)
Lists Data Fusion instances in the specified project and location.
listNamespaces(ListNamespacesRequest request)
public ListenableFuture<ListNamespacesResponse> listNamespaces(ListNamespacesRequest request)
List namespaces in a given instance
removeDnsPeering(RemoveDnsPeeringRequest request)
public ListenableFuture<RemoveDnsPeeringResponse> removeDnsPeering(RemoveDnsPeeringRequest request)
Remove DNS peering on the given resource.
removeIamPolicy(RemoveIamPolicyRequest request)
public ListenableFuture<RemoveIamPolicyResponse> removeIamPolicy(RemoveIamPolicyRequest request)
Remove IAM policy that is currently set on the given resource.
restartInstance(RestartInstanceRequest request)
public ListenableFuture<Operation> restartInstance(RestartInstanceRequest request)
Restart a single Data Fusion instance.
At the end of an operation instance is fully restarted.
Returns |
---|
Type | Description |
com.google.common.util.concurrent.ListenableFuture<Operation> | |
updateInstance(UpdateInstanceRequest request)
public ListenableFuture<Operation> updateInstance(UpdateInstanceRequest request)
Updates a single Data Fusion instance.
Returns |
---|
Type | Description |
com.google.common.util.concurrent.ListenableFuture<Operation> | |
upgradeInstance(UpgradeInstanceRequest request)
public ListenableFuture<Operation> upgradeInstance(UpgradeInstanceRequest request)
Upgrade a single Data Fusion instance.
At the end of an operation instance is fully upgraded.
Returns |
---|
Type | Description |
com.google.common.util.concurrent.ListenableFuture<Operation> | |