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.

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
protected SubmitGrpc.SubmitFutureStub	build(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.AbstractFutureStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected SubmitGrpc.SubmitFutureStub build(io.grpc.Channel channel,
                                            io.grpc.CallOptions callOptions)

Specified by:

build in class io.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)