Package api

Class SubmitGrpc.SubmitStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<SubmitGrpc.SubmitStub>

api.SubmitGrpc.SubmitStub

Enclosing class:

SubmitGrpc

public static final class SubmitGrpc.SubmitStub
extends io.grpc.stub.AbstractAsyncStub<SubmitGrpc.SubmitStub>

A stub to allow clients to do asynchronous 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.SubmitStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	cancelJobs(SubmitOuterClass.JobCancelRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.CancellationResult> responseObserver)
void	cancelJobSet(SubmitOuterClass.JobSetCancelRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	createQueue(SubmitOuterClass.Queue request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	createQueues(SubmitOuterClass.QueueList request, io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueCreateResponse> responseObserver)
void	deleteQueue(SubmitOuterClass.QueueDeleteRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	getQueue(SubmitOuterClass.QueueGetRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.Queue> responseObserver)
void	getQueues(SubmitOuterClass.StreamingQueueGetRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.StreamingQueueMessage> responseObserver)
void	health(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<Health.HealthCheckResponse> responseObserver)
void	preemptJobs(SubmitOuterClass.JobPreemptRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	reprioritizeJobs(SubmitOuterClass.JobReprioritizeRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.JobReprioritizeResponse> responseObserver)
void	submitJobs(SubmitOuterClass.JobSubmitRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.JobSubmitResponse> responseObserver)
void	updateQueue(SubmitOuterClass.Queue request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
void	updateQueues(SubmitOuterClass.QueueList request, io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueUpdateResponse> responseObserver)

Methods inherited from class io.grpc.stub.AbstractAsyncStub

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.SubmitStub build(io.grpc.Channel channel,
                                      io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<SubmitGrpc.SubmitStub>

submitJobs

public void submitJobs(SubmitOuterClass.JobSubmitRequest request,
                       io.grpc.stub.StreamObserver<SubmitOuterClass.JobSubmitResponse> responseObserver)

cancelJobs

public void cancelJobs(SubmitOuterClass.JobCancelRequest request,
                       io.grpc.stub.StreamObserver<SubmitOuterClass.CancellationResult> responseObserver)

cancelJobSet

public void cancelJobSet(SubmitOuterClass.JobSetCancelRequest request,
                         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

reprioritizeJobs

public void reprioritizeJobs(SubmitOuterClass.JobReprioritizeRequest request,
                             io.grpc.stub.StreamObserver<SubmitOuterClass.JobReprioritizeResponse> responseObserver)

preemptJobs

public void preemptJobs(SubmitOuterClass.JobPreemptRequest request,
                        io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

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)

health

public void health(com.google.protobuf.Empty request,
                   io.grpc.stub.StreamObserver<Health.HealthCheckResponse> responseObserver)