Package api
Class SubmitGrpc.SubmitFutureStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractFutureStub<SubmitGrpc.SubmitFutureStub>
-
- api.SubmitGrpc.SubmitFutureStub
-
- Enclosing class:
- SubmitGrpc
public static final class SubmitGrpc.SubmitFutureStub extends io.grpc.stub.AbstractFutureStub<SubmitGrpc.SubmitFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service Submit.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected SubmitGrpc.SubmitFutureStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions)com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.CancellationResult>cancelJobs(SubmitOuterClass.JobCancelRequest request)com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>cancelJobSet(SubmitOuterClass.JobSetCancelRequest request)com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>createQueue(SubmitOuterClass.Queue request)com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.BatchQueueCreateResponse>createQueues(SubmitOuterClass.QueueList request)com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>deleteQueue(SubmitOuterClass.QueueDeleteRequest request)com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.Queue>getQueue(SubmitOuterClass.QueueGetRequest request)com.google.common.util.concurrent.ListenableFuture<Health.HealthCheckResponse>health(com.google.protobuf.Empty request)com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>preemptJobs(SubmitOuterClass.JobPreemptRequest request)com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.JobReprioritizeResponse>reprioritizeJobs(SubmitOuterClass.JobReprioritizeRequest request)com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.JobSubmitResponse>submitJobs(SubmitOuterClass.JobSubmitRequest request)com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>updateQueue(SubmitOuterClass.Queue request)com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.BatchQueueUpdateResponse>updateQueues(SubmitOuterClass.QueueList request)-
Methods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
-
-
-
Method Detail
-
build
protected SubmitGrpc.SubmitFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
buildin classio.grpc.stub.AbstractStub<SubmitGrpc.SubmitFutureStub>
-
submitJobs
public com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.JobSubmitResponse> submitJobs(SubmitOuterClass.JobSubmitRequest request)
-
cancelJobs
public com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.CancellationResult> cancelJobs(SubmitOuterClass.JobCancelRequest request)
-
cancelJobSet
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> cancelJobSet(SubmitOuterClass.JobSetCancelRequest request)
-
reprioritizeJobs
public com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.JobReprioritizeResponse> reprioritizeJobs(SubmitOuterClass.JobReprioritizeRequest request)
-
preemptJobs
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> preemptJobs(SubmitOuterClass.JobPreemptRequest request)
-
createQueue
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> createQueue(SubmitOuterClass.Queue request)
-
createQueues
public com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.BatchQueueCreateResponse> createQueues(SubmitOuterClass.QueueList request)
-
updateQueue
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> updateQueue(SubmitOuterClass.Queue request)
-
updateQueues
public com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.BatchQueueUpdateResponse> updateQueues(SubmitOuterClass.QueueList request)
-
deleteQueue
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteQueue(SubmitOuterClass.QueueDeleteRequest request)
-
getQueue
public com.google.common.util.concurrent.ListenableFuture<SubmitOuterClass.Queue> getQueue(SubmitOuterClass.QueueGetRequest request)
-
health
public com.google.common.util.concurrent.ListenableFuture<Health.HealthCheckResponse> health(com.google.protobuf.Empty request)
-
-