alluxio.grpc

Class JobMasterClientServiceGrpc.JobMasterClientServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<JobMasterClientServiceGrpc.JobMasterClientServiceStub>

alluxio.grpc.JobMasterClientServiceGrpc.JobMasterClientServiceStub

Enclosing class:

JobMasterClientServiceGrpc

public static final class JobMasterClientServiceGrpc.JobMasterClientServiceStub
extends io.grpc.stub.AbstractAsyncStub<JobMasterClientServiceGrpc.JobMasterClientServiceStub>

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

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
protected JobMasterClientServiceGrpc.JobMasterClientServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
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 io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected JobMasterClientServiceGrpc.JobMasterClientServiceStub build(io.grpc.Channel channel,
                                                                      io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<JobMasterClientServiceGrpc.JobMasterClientServiceStub>

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.