public static final class JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub extends io.grpc.stub.AbstractFutureStub<JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub>
This interface contains job master service endpoints for job service clients.
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<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<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.
|
protected JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<JobMasterClientServiceGrpc.JobMasterClientServiceFutureStub>
public com.google.common.util.concurrent.ListenableFuture<CancelPResponse> cancel(CancelPRequest request)
Cancels the given job.
public com.google.common.util.concurrent.ListenableFuture<GetJobStatusPResponse> getJobStatus(GetJobStatusPRequest request)
Gets the status of the given job.
public com.google.common.util.concurrent.ListenableFuture<GetJobServiceSummaryPResponse> getJobServiceSummary(GetJobServiceSummaryPRequest request)
Gets the summary of the job service.
public com.google.common.util.concurrent.ListenableFuture<ListAllPResponse> listAll(ListAllPRequest request)
Lists ids of all known jobs.
public com.google.common.util.concurrent.ListenableFuture<RunPResponse> run(RunPRequest request)
Starts the given job, returning a job id.
public com.google.common.util.concurrent.ListenableFuture<GetAllWorkerHealthPResponse> getAllWorkerHealth(GetAllWorkerHealthPRequest request)
Lists all worker health.
Copyright © 2023. All Rights Reserved.