alluxio.grpc

Class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub>

alluxio.grpc.JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub

Enclosing class:

JobMasterWorkerServiceGrpc

public static final class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub
extends io.grpc.stub.AbstractStub<JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub>

 This interface contains job master service endpoints for job service workers.
 

Method Summary

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.

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

build

protected JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub build(io.grpc.Channel channel,
                                                                      io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<JobMasterWorkerServiceGrpc.JobMasterWorkerServiceStub>

heartbeat

public void heartbeat(JobHeartbeatPRequest request,
                      io.grpc.stub.StreamObserver<JobHeartbeatPResponse> responseObserver)

 Periodic worker heartbeat returns a list of commands for the worker to execute.
 

registerJobWorker

public void registerJobWorker(RegisterJobWorkerPRequest request,
                              io.grpc.stub.StreamObserver<RegisterJobWorkerPResponse> responseObserver)

 Returns a worker id for the given network address.