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	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 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.
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService