Package api

Interface SubmitGrpc.AsyncService

All Known Implementing Classes:

SubmitGrpc.SubmitImplBase

Enclosing class:

SubmitGrpc

public static interface SubmitGrpc.AsyncService

Method Summary

Modifier and Type	Method	Description
default void	cancelJobs(SubmitOuterClass.JobCancelRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.CancellationResult> responseObserver)
default void	cancelJobSet(SubmitOuterClass.JobSetCancelRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	createQueue(SubmitOuterClass.Queue request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	createQueues(SubmitOuterClass.QueueList request, io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueCreateResponse> responseObserver)
default void	deleteQueue(SubmitOuterClass.QueueDeleteRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	getQueue(SubmitOuterClass.QueueGetRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.Queue> responseObserver)
default void	getQueues(SubmitOuterClass.StreamingQueueGetRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.StreamingQueueMessage> responseObserver)
default void	health(com.google.protobuf.Empty request, io.grpc.stub.StreamObserver<Health.HealthCheckResponse> responseObserver)
default void	preemptJobs(SubmitOuterClass.JobPreemptRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	reprioritizeJobs(SubmitOuterClass.JobReprioritizeRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.JobReprioritizeResponse> responseObserver)
default void	submitJobs(SubmitOuterClass.JobSubmitRequest request, io.grpc.stub.StreamObserver<SubmitOuterClass.JobSubmitResponse> responseObserver)
default void	updateQueue(SubmitOuterClass.Queue request, io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
default void	updateQueues(SubmitOuterClass.QueueList request, io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueUpdateResponse> responseObserver)

Method Detail

submitJobs

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

cancelJobs

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

cancelJobSet

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

reprioritizeJobs

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

preemptJobs

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

createQueue

default void createQueue(SubmitOuterClass.Queue request,
                         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

createQueues

default void createQueues(SubmitOuterClass.QueueList request,
                          io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueCreateResponse> responseObserver)

updateQueue

default void updateQueue(SubmitOuterClass.Queue request,
                         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

updateQueues

default void updateQueues(SubmitOuterClass.QueueList request,
                          io.grpc.stub.StreamObserver<SubmitOuterClass.BatchQueueUpdateResponse> responseObserver)

deleteQueue

default void deleteQueue(SubmitOuterClass.QueueDeleteRequest request,
                         io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)

getQueue

default void getQueue(SubmitOuterClass.QueueGetRequest request,
                      io.grpc.stub.StreamObserver<SubmitOuterClass.Queue> responseObserver)

getQueues

default void getQueues(SubmitOuterClass.StreamingQueueGetRequest request,
                       io.grpc.stub.StreamObserver<SubmitOuterClass.StreamingQueueMessage> responseObserver)

health

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