alluxio.master.job

Class JobMasterClientServiceHandler

java.lang.Object

alluxio.grpc.JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

alluxio.master.job.JobMasterClientServiceHandler

All Implemented Interfaces:

JobMasterClientServiceGrpc.AsyncService, io.grpc.BindableService

public class JobMasterClientServiceHandler
extends JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

This class is a gRPC handler for job master RPCs invoked by a job service client.

Constructor Summary

Constructors

Constructor and Description
JobMasterClientServiceHandler(JobMaster jobMaster) Creates a new instance of JobMasterClientRestServiceHandler.

Method Summary

Modifier and Type	Method and Description
void	cancel(CancelPRequest request, io.grpc.stub.StreamObserver<CancelPResponse> responseObserver) Cancels the given job.
void	getAllMasterStatus(GetAllMasterStatusPRequest request, io.grpc.stub.StreamObserver<GetAllMasterStatusPResponse> responseObserver) Lists all job master status.
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 alluxio.grpc.JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

JobMasterClientServiceHandler

public JobMasterClientServiceHandler(JobMaster jobMaster)

Creates a new instance of JobMasterClientRestServiceHandler.

Parameters:

jobMaster - the job master to use

Method Detail

cancel

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Cancels the given job.
 

getJobStatus

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Gets the status of the given job.
 

getJobStatusDetailed

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Gets the status of the given job.
 

getJobServiceSummary

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Gets the summary of the job service.
 

listAll

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Lists ids of all known jobs.
 

run

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Starts the given job, returning a job id.
 

getAllWorkerHealth

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Lists all worker health.
 

getAllMasterStatus

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Lists all job master status.
 

submit

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Submit a CMD job, return a jobControlId.
 

getCmdStatus

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

 Get status for a CMD job, return a status.
 

getCmdStatusDetailed

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

Description copied from interface: JobMasterClientServiceGrpc.AsyncService

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