@ThreadSafe public final class JobMasterWorkerServiceHandler extends JobMasterWorkerServiceGrpc.JobMasterWorkerServiceImplBase
Constructor and Description |
---|
JobMasterWorkerServiceHandler(JobMaster JobMaster)
Creates a new instance of
JobMasterWorkerServiceHandler . |
Modifier and Type | Method and Description |
---|---|
void |
heartbeat(JobHeartbeatPRequest request,
io.grpc.stub.StreamObserver<JobHeartbeatPResponse> responseObserver)
Periodic worker heartbeat returns a list of commands for the worker to execute.
|
void |
registerJobWorker(RegisterJobWorkerPRequest request,
io.grpc.stub.StreamObserver<RegisterJobWorkerPResponse> responseObserver)
Returns a worker id for the given network address.
|
bindService
public JobMasterWorkerServiceHandler(JobMaster JobMaster)
JobMasterWorkerServiceHandler
.JobMaster
- the JobMaster
that the handler uses internallypublic void heartbeat(JobHeartbeatPRequest request, io.grpc.stub.StreamObserver<JobHeartbeatPResponse> responseObserver)
JobMasterWorkerServiceGrpc.AsyncService
Periodic worker heartbeat returns a list of commands for the worker to execute.
public void registerJobWorker(RegisterJobWorkerPRequest request, io.grpc.stub.StreamObserver<RegisterJobWorkerPResponse> responseObserver)
JobMasterWorkerServiceGrpc.AsyncService
Returns a worker id for the given network address.
Copyright © 2023. All Rights Reserved.