alluxio.grpc

Interface JobMasterClientServiceGrpc.AsyncService

All Known Implementing Classes:

JobMasterClientServiceGrpc.JobMasterClientServiceImplBase, JobMasterClientServiceHandler

Enclosing class:

JobMasterClientServiceGrpc

public static interface JobMasterClientServiceGrpc.AsyncService

 This interface contains job master service endpoints for job service clients.
 

Method Summary

Modifier and Type	Method and Description
default void	cancel(CancelPRequest request, io.grpc.stub.StreamObserver<CancelPResponse> responseObserver) Cancels the given job.
default void	getAllMasterStatus(GetAllMasterStatusPRequest request, io.grpc.stub.StreamObserver<GetAllMasterStatusPResponse> responseObserver) Lists all job master status.
default void	getAllWorkerHealth(GetAllWorkerHealthPRequest request, io.grpc.stub.StreamObserver<GetAllWorkerHealthPResponse> responseObserver) Lists all worker health.
default void	getCmdStatus(GetCmdStatusRequest request, io.grpc.stub.StreamObserver<GetCmdStatusResponse> responseObserver) Get status for a CMD job, return a status.
default void	getCmdStatusDetailed(GetCmdStatusDetailedRequest request, io.grpc.stub.StreamObserver<GetCmdStatusDetailedResponse> responseObserver) Get detailed status for a CMD job, return detailed status information.
default void	getJobServiceSummary(GetJobServiceSummaryPRequest request, io.grpc.stub.StreamObserver<GetJobServiceSummaryPResponse> responseObserver) Gets the summary of the job service.
default void	getJobStatus(GetJobStatusPRequest request, io.grpc.stub.StreamObserver<GetJobStatusPResponse> responseObserver) Gets the status of the given job.
default void	getJobStatusDetailed(GetJobStatusDetailedPRequest request, io.grpc.stub.StreamObserver<GetJobStatusDetailedPResponse> responseObserver) Gets the status of the given job.
default void	listAll(ListAllPRequest request, io.grpc.stub.StreamObserver<ListAllPResponse> responseObserver) Lists ids of all known jobs.
default void	run(RunPRequest request, io.grpc.stub.StreamObserver<RunPResponse> responseObserver) Starts the given job, returning a job id.
default void	submit(SubmitRequest request, io.grpc.stub.StreamObserver<SubmitResponse> responseObserver) Submit a CMD job, return a jobControlId.

Method Detail

cancel

default void cancel(CancelPRequest request,
                    io.grpc.stub.StreamObserver<CancelPResponse> responseObserver)

 Cancels the given job.
 

getJobStatus

default void getJobStatus(GetJobStatusPRequest request,
                          io.grpc.stub.StreamObserver<GetJobStatusPResponse> responseObserver)

 Gets the status of the given job.
 

getJobStatusDetailed

default void getJobStatusDetailed(GetJobStatusDetailedPRequest request,
                                  io.grpc.stub.StreamObserver<GetJobStatusDetailedPResponse> responseObserver)

 Gets the status of the given job.
 

getJobServiceSummary

default void getJobServiceSummary(GetJobServiceSummaryPRequest request,
                                  io.grpc.stub.StreamObserver<GetJobServiceSummaryPResponse> responseObserver)

 Gets the summary of the job service.
 

listAll

default void listAll(ListAllPRequest request,
                     io.grpc.stub.StreamObserver<ListAllPResponse> responseObserver)

 Lists ids of all known jobs.
 

run

default void run(RunPRequest request,
                 io.grpc.stub.StreamObserver<RunPResponse> responseObserver)

 Starts the given job, returning a job id.
 

getAllWorkerHealth

default void getAllWorkerHealth(GetAllWorkerHealthPRequest request,
                                io.grpc.stub.StreamObserver<GetAllWorkerHealthPResponse> responseObserver)

 Lists all worker health.
 

getAllMasterStatus

default void getAllMasterStatus(GetAllMasterStatusPRequest request,
                                io.grpc.stub.StreamObserver<GetAllMasterStatusPResponse> responseObserver)

 Lists all job master status.
 

submit

default void submit(SubmitRequest request,
                    io.grpc.stub.StreamObserver<SubmitResponse> responseObserver)

 Submit a CMD job, return a jobControlId.
 

getCmdStatus

default void getCmdStatus(GetCmdStatusRequest request,
                          io.grpc.stub.StreamObserver<GetCmdStatusResponse> responseObserver)

 Get status for a CMD job, return a status.
 

getCmdStatusDetailed

default void getCmdStatusDetailed(GetCmdStatusDetailedRequest request,
                                  io.grpc.stub.StreamObserver<GetCmdStatusDetailedResponse> responseObserver)

 Get detailed status for a CMD job, return detailed status information.