alluxio.grpc

Class JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub>

alluxio.grpc.JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub

Enclosing class:

JobMasterClientServiceGrpc

public static final class JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub>

 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.JobMasterClientServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<CancelPResponse>	cancel(CancelPRequest request) Cancels the given job.
com.google.common.util.concurrent.ListenableFuture<GetAllWorkerHealthPResponse>	getAllWorkerHealth(GetAllWorkerHealthPRequest request) Lists all worker health.
com.google.common.util.concurrent.ListenableFuture<GetCmdStatusResponse>	getCmdStatus(GetCmdStatusRequest request) Get status for a CMD job, return a status.
com.google.common.util.concurrent.ListenableFuture<GetCmdStatusDetailedResponse>	getCmdStatusDetailed(GetCmdStatusDetailedRequest request) Get detailed status for a CMD job, return detailed status information.
com.google.common.util.concurrent.ListenableFuture<GetJobServiceSummaryPResponse>	getJobServiceSummary(GetJobServiceSummaryPRequest request) Gets the summary of the job service.
com.google.common.util.concurrent.ListenableFuture<GetJobStatusPResponse>	getJobStatus(GetJobStatusPRequest request) Gets the status of the given job.
com.google.common.util.concurrent.ListenableFuture<GetJobStatusDetailedPResponse>	getJobStatusDetailed(GetJobStatusDetailedPRequest request) Gets the status of the given job.
com.google.common.util.concurrent.ListenableFuture<ListAllPResponse>	listAll(ListAllPRequest request) Lists ids of all known jobs.
com.google.common.util.concurrent.ListenableFuture<RunPResponse>	run(RunPRequest request) Starts the given job, returning a job id.
com.google.common.util.concurrent.ListenableFuture<SubmitResponse>	submit(SubmitRequest request) Submit a CMD job, return a jobControlId.

Methods inherited from class io.grpc.stub.AbstractFutureStub

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.JobMasterClientServiceFutureStub build(io.grpc.Channel channel,
                                                                            io.grpc.CallOptions callOptions)

Specified by:

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

cancel

public com.google.common.util.concurrent.ListenableFuture<CancelPResponse> cancel(CancelPRequest request)

 Cancels the given job.
 

getJobStatus

public com.google.common.util.concurrent.ListenableFuture<GetJobStatusPResponse> getJobStatus(GetJobStatusPRequest request)

 Gets the status of the given job.
 

getJobStatusDetailed

public com.google.common.util.concurrent.ListenableFuture<GetJobStatusDetailedPResponse> getJobStatusDetailed(GetJobStatusDetailedPRequest request)

 Gets the status of the given job.
 

getJobServiceSummary

public com.google.common.util.concurrent.ListenableFuture<GetJobServiceSummaryPResponse> getJobServiceSummary(GetJobServiceSummaryPRequest request)

 Gets the summary of the job service.
 

listAll

public com.google.common.util.concurrent.ListenableFuture<ListAllPResponse> listAll(ListAllPRequest request)

 Lists ids of all known jobs.
 

run

public com.google.common.util.concurrent.ListenableFuture<RunPResponse> run(RunPRequest request)

 Starts the given job, returning a job id.
 

getAllWorkerHealth

public com.google.common.util.concurrent.ListenableFuture<GetAllWorkerHealthPResponse> getAllWorkerHealth(GetAllWorkerHealthPRequest request)

 Lists all worker health.
 

submit

public com.google.common.util.concurrent.ListenableFuture<SubmitResponse> submit(SubmitRequest request)

 Submit a CMD job, return a jobControlId.
 

getCmdStatus

public com.google.common.util.concurrent.ListenableFuture<GetCmdStatusResponse> getCmdStatus(GetCmdStatusRequest request)

 Get status for a CMD job, return a status.
 

getCmdStatusDetailed

public com.google.common.util.concurrent.ListenableFuture<GetCmdStatusDetailedResponse> getCmdStatusDetailed(GetCmdStatusDetailedRequest request)

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