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