public static final class AppPlatformGrpc.AppPlatformFutureStub extends AbstractFutureStub<AppPlatformGrpc.AppPlatformFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service AppPlatform.
Service describing handlers for resources
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractFutureStub >
AppPlatformGrpc.AppPlatformFutureStub
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.withOnReadyThreshold(int)
io.grpc.stub.AbstractStub.withWaitForReady()
Methods
public ListenableFuture<Operation> addApplicationStreamInput(AddApplicationStreamInputRequest request)
Adds target stream input to the Application.
If the Application is deployed, the corresponding new Application instance
will be created. If the stream has already been in the Application, the RPC
will fail.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
protected AppPlatformGrpc.AppPlatformFutureStub 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)
public ListenableFuture<Operation> createApplication(CreateApplicationRequest request)
Creates a new Application in a given project and location.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> createApplicationInstances(CreateApplicationInstancesRequest request)
Adds target stream input to the Application.
If the Application is deployed, the corresponding new Application instance
will be created. If the stream has already been in the Application, the RPC
will fail.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> createDraft(CreateDraftRequest request)
Creates a new Draft in a given project and location.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> createProcessor(CreateProcessorRequest request)
Creates a new Processor in a given project and location.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> deleteApplication(DeleteApplicationRequest request)
Deletes a single Application.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> deleteApplicationInstances(DeleteApplicationInstancesRequest request)
Remove target stream input to the Application, if the Application is
deployed, the corresponding instance based will be deleted. If the stream
is not in the Application, the RPC will fail.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> deleteDraft(DeleteDraftRequest request)
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> deleteProcessor(DeleteProcessorRequest request)
Deletes a single Processor.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> deployApplication(DeployApplicationRequest request)
Deploys a single Application.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Application> getApplication(GetApplicationRequest request)
Gets details of a single Application.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Application> |
|
public ListenableFuture<Draft> getDraft(GetDraftRequest request)
Gets details of a single Draft.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Draft> |
|
public ListenableFuture<Instance> getInstance(GetInstanceRequest request)
Gets details of a single Instance.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Instance> |
|
public ListenableFuture<Processor> getProcessor(GetProcessorRequest request)
Gets details of a single Processor.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Processor> |
|
public ListenableFuture<ListApplicationsResponse> listApplications(ListApplicationsRequest request)
Lists Applications in a given project and location.
public ListenableFuture<ListDraftsResponse> listDrafts(ListDraftsRequest request)
Lists Drafts in a given project and location.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<ListDraftsResponse> |
|
public ListenableFuture<ListInstancesResponse> listInstances(ListInstancesRequest request)
Lists Instances in a given project and location.
public ListenableFuture<ListPrebuiltProcessorsResponse> listPrebuiltProcessors(ListPrebuiltProcessorsRequest request)
ListPrebuiltProcessors is a custom pass-through verb that Lists Prebuilt
Processors.
public ListenableFuture<ListProcessorsResponse> listProcessors(ListProcessorsRequest request)
Lists Processors in a given project and location.
public ListenableFuture<Operation> removeApplicationStreamInput(RemoveApplicationStreamInputRequest request)
Remove target stream input to the Application, if the Application is
deployed, the corresponding instance based will be deleted. If the stream
is not in the Application, the RPC will fail.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> undeployApplication(UndeployApplicationRequest request)
Undeploys a single Application.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> updateApplication(UpdateApplicationRequest request)
Updates the parameters of a single Application.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> updateApplicationInstances(UpdateApplicationInstancesRequest request)
Adds target stream input to the Application.
If the Application is deployed, the corresponding new Application instance
will be created. If the stream has already been in the Application, the RPC
will fail.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> updateApplicationStreamInput(UpdateApplicationStreamInputRequest request)
Update target stream input to the Application, if the Application is
deployed, the corresponding instance based will be deployed. For
CreateOrUpdate behavior, set allow_missing to true.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> updateDraft(UpdateDraftRequest request)
Updates the parameters of a single Draft.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|
public ListenableFuture<Operation> updateProcessor(UpdateProcessorRequest request)
Updates the parameters of a single Processor.
Returns |
Type |
Description |
com.google.common.util.concurrent.ListenableFuture<Operation> |
|