alluxio.grpc

Class JobMasterWorkerServiceGrpc.JobMasterWorkerServiceFutureStub

java.lang.Object

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

alluxio.grpc.JobMasterWorkerServiceGrpc.JobMasterWorkerServiceFutureStub

Enclosing class:

JobMasterWorkerServiceGrpc

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

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

Method Summary

Modifier and Type	Method and Description
protected JobMasterWorkerServiceGrpc.JobMasterWorkerServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<JobHeartbeatPResponse>	heartbeat(JobHeartbeatPRequest request) Periodic worker heartbeat returns a list of commands for the worker to execute.
com.google.common.util.concurrent.ListenableFuture<RegisterJobWorkerPResponse>	registerJobWorker(RegisterJobWorkerPRequest request) 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.JobMasterWorkerServiceFutureStub build(io.grpc.Channel channel,
                                                                            io.grpc.CallOptions callOptions)

Specified by:

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

heartbeat

public com.google.common.util.concurrent.ListenableFuture<JobHeartbeatPResponse> heartbeat(JobHeartbeatPRequest request)

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

registerJobWorker

public com.google.common.util.concurrent.ListenableFuture<RegisterJobWorkerPResponse> registerJobWorker(RegisterJobWorkerPRequest request)

 Returns a worker id for the given network address.