alluxio.master.job

Class JobMasterClientServiceHandler

java.lang.Object

alluxio.grpc.JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

alluxio.master.job.JobMasterClientServiceHandler

All Implemented Interfaces:

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	getAllWorkerHealth(GetAllWorkerHealthPRequest request, io.grpc.stub.StreamObserver<GetAllWorkerHealthPResponse> responseObserver) Lists all worker health.
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.

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 class: JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

 Cancels the given job.
 

Overrides:

cancel in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

getJobStatus

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

Description copied from class: JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

 Gets the status of the given job.
 

Overrides:

getJobStatus in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

getJobStatusDetailed

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

Description copied from class: JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

 Gets the status of the given job.
 

Overrides:

getJobStatusDetailed in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

getJobServiceSummary

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

Description copied from class: JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

 Gets the summary of the job service.
 

Overrides:

getJobServiceSummary in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

listAll

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

Description copied from class: JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

 Lists ids of all known jobs.
 

Overrides:

listAll in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

run

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

Description copied from class: JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

 Starts the given job, returning a job id.
 

Overrides:

run in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

getAllWorkerHealth

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

Description copied from class: JobMasterClientServiceGrpc.JobMasterClientServiceImplBase

 Lists all worker health.
 

Overrides:

getAllWorkerHealth in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase