Package api

Class QueueServiceGrpc.QueueServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<QueueServiceGrpc.QueueServiceFutureStub>

api.QueueServiceGrpc.QueueServiceFutureStub

Enclosing class:

QueueServiceGrpc

public static final class QueueServiceGrpc.QueueServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<QueueServiceGrpc.QueueServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service QueueService.

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 QueueServiceGrpc.QueueServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>	cancelOnQueue(SubmitOuterClass.QueueCancelRequest request)
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>	cordonQueue(SubmitOuterClass.QueueCordonRequest 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<com.google.protobuf.Empty>	preemptOnQueue(SubmitOuterClass.QueuePreemptRequest request)
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>	uncordonQueue(SubmitOuterClass.QueueUncordonRequest 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 QueueServiceGrpc.QueueServiceFutureStub build(io.grpc.Channel channel,
                                                        io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<QueueServiceGrpc.QueueServiceFutureStub>

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)

cordonQueue

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> cordonQueue(SubmitOuterClass.QueueCordonRequest request)

uncordonQueue

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> uncordonQueue(SubmitOuterClass.QueueUncordonRequest request)

preemptOnQueue

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> preemptOnQueue(SubmitOuterClass.QueuePreemptRequest request)

cancelOnQueue

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> cancelOnQueue(SubmitOuterClass.QueueCancelRequest request)