Package api
Class QueueServiceGrpc.QueueServiceStub
- java.lang.Object
-
- io.grpc.stub.AbstractStub<S>
-
- io.grpc.stub.AbstractAsyncStub<QueueServiceGrpc.QueueServiceStub>
-
- api.QueueServiceGrpc.QueueServiceStub
-
- Enclosing class:
- QueueServiceGrpc
public static final class QueueServiceGrpc.QueueServiceStub extends io.grpc.stub.AbstractAsyncStub<QueueServiceGrpc.QueueServiceStub>
A stub to allow clients to do asynchronous rpc calls to service QueueService.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected QueueServiceGrpc.QueueServiceStubbuild(io.grpc.Channel channel, io.grpc.CallOptions callOptions)voidcancelOnQueue(SubmitOuterClass.QueueCancelRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)voidcordonQueue(SubmitOuterClass.QueueCordonRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)voidcreateQueue(SubmitOuterClass.Queue request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)voidcreateQueues(SubmitOuterClass.QueueList request, io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueCreateResponse> responseObserver)voiddeleteQueue(SubmitOuterClass.QueueDeleteRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)voidgetQueue(SubmitOuterClass.QueueGetRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.Queue> responseObserver)voidgetQueues(SubmitOuterClass.StreamingQueueGetRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.StreamingQueueMessage> responseObserver)voidpreemptOnQueue(SubmitOuterClass.QueuePreemptRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)voiduncordonQueue(SubmitOuterClass.QueueUncordonRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)voidupdateQueue(SubmitOuterClass.Queue request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)voidupdateQueues(SubmitOuterClass.QueueList request, io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueUpdateResponse> responseObserver)-
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 QueueServiceGrpc.QueueServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
- Specified by:
buildin classio.grpc.stub.AbstractStub<QueueServiceGrpc.QueueServiceStub>
-
createQueue
public void createQueue(SubmitOuterClass.Queue request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
-
createQueues
public void createQueues(SubmitOuterClass.QueueList request, io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueCreateResponse> responseObserver)
-
updateQueue
public void updateQueue(SubmitOuterClass.Queue request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
-
updateQueues
public void updateQueues(SubmitOuterClass.QueueList request, io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueUpdateResponse> responseObserver)
-
deleteQueue
public void deleteQueue(SubmitOuterClass.QueueDeleteRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
-
getQueue
public void getQueue(SubmitOuterClass.QueueGetRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.Queue> responseObserver)
-
getQueues
public void getQueues(SubmitOuterClass.StreamingQueueGetRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.StreamingQueueMessage> responseObserver)
-
cordonQueue
public void cordonQueue(SubmitOuterClass.QueueCordonRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
-
uncordonQueue
public void uncordonQueue(SubmitOuterClass.QueueUncordonRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
-
preemptOnQueue
public void preemptOnQueue(SubmitOuterClass.QueuePreemptRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
-
cancelOnQueue
public void cancelOnQueue(SubmitOuterClass.QueueCancelRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
-
-