alluxio.grpc

Class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

java.lang.Object

alluxio.grpc.JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

JobMasterClientServiceHandler

Enclosing class:

JobMasterClientServiceGrpc

public abstract static class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
extends Object
implements io.grpc.BindableService

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

Constructor Summary

Constructors

Constructor and Description
JobMasterClientServiceImplBase()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobMasterClientServiceImplBase

public JobMasterClientServiceImplBase()

Method Detail

cancel

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

 Cancels the given job.
 

getJobStatus

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

 Gets the status of the given job.
 

getJobStatusDetailed

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

 Gets the status of the given job.
 

getJobServiceSummary

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

 Gets the summary of the job service.
 

listAll

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

 Lists ids of all known jobs.
 

run

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

 Starts the given job, returning a job id.
 

getAllWorkerHealth

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

 Lists all worker health.
 

submit

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

 Submit a CMD job, return a jobControlId.
 

getCmdStatus

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

 Get status for a CMD job, return a status.
 

getCmdStatusDetailed

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

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

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService