public class JobMasterClientServiceHandler extends JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Constructor and Description |
---|
JobMasterClientServiceHandler(JobMaster jobMaster)
Creates a new instance of
JobMasterClientRestServiceHandler . |
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.
|
bindService
public JobMasterClientServiceHandler(JobMaster jobMaster)
JobMasterClientRestServiceHandler
.jobMaster
- the job master to usepublic void cancel(CancelPRequest request, io.grpc.stub.StreamObserver<CancelPResponse> responseObserver)
JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Cancels the given job.
cancel
in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
public void getJobStatus(GetJobStatusPRequest request, io.grpc.stub.StreamObserver<GetJobStatusPResponse> responseObserver)
JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Gets the status of the given job.
getJobStatus
in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
public void getJobStatusDetailed(GetJobStatusDetailedPRequest request, io.grpc.stub.StreamObserver<GetJobStatusDetailedPResponse> responseObserver)
JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Gets the status of the given job.
getJobStatusDetailed
in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
public void getJobServiceSummary(GetJobServiceSummaryPRequest request, io.grpc.stub.StreamObserver<GetJobServiceSummaryPResponse> responseObserver)
JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Gets the summary of the job service.
getJobServiceSummary
in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
public void listAll(ListAllPRequest request, io.grpc.stub.StreamObserver<ListAllPResponse> responseObserver)
JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Lists ids of all known jobs.
listAll
in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
public void run(RunPRequest request, io.grpc.stub.StreamObserver<RunPResponse> responseObserver)
JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Starts the given job, returning a job id.
run
in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
public void getAllWorkerHealth(GetAllWorkerHealthPRequest request, io.grpc.stub.StreamObserver<GetAllWorkerHealthPResponse> responseObserver)
JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Lists all worker health.
getAllWorkerHealth
in class JobMasterClientServiceGrpc.JobMasterClientServiceImplBase
Copyright © 2023. All Rights Reserved.