public static final class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub extends io.grpc.stub.AbstractAsyncStub<JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub>
This interface contains job master service endpoints for job service workers.
Modifier and Type | Method and Description |
---|---|
protected JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
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.
|
protected JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub>
public void heartbeat(JobHeartbeatPRequest request, io.grpc.stub.StreamObserver<JobHeartbeatPResponse> responseObserver)
Periodic worker heartbeat returns a list of commands for the worker to execute.
public void registerJobWorker(RegisterJobWorkerPRequest request, io.grpc.stub.StreamObserver<RegisterJobWorkerPResponse> responseObserver)
Returns a worker id for the given network address.
Copyright © 2023. All Rights Reserved.