alluxio.grpc

Class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub>

alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub

Enclosing class:

BlockMasterWorkerServiceGrpc

public static final class BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service BlockMasterWorkerService.

 This interface contains block master service endpoints for Alluxio workers.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<BlockHeartbeatPResponse>	blockHeartbeat(BlockHeartbeatPRequest request) Periodic block worker heartbeat returns an optional command for the block worker to execute.
protected BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<CommitBlockPResponse>	commitBlock(CommitBlockPRequest request) Marks the given block as committed.
com.google.common.util.concurrent.ListenableFuture<GetWorkerIdPResponse>	getWorkerId(GetWorkerIdPRequest request) Returns a worker id for the given network address.
com.google.common.util.concurrent.ListenableFuture<NotifyWorkerIdPResponse>	notifyWorkerId(NotifyWorkerIdPRequest request) Notify all masters about the worker ID.
com.google.common.util.concurrent.ListenableFuture<RegisterWorkerPResponse>	registerWorker(RegisterWorkerPRequest request) Registers a worker.
com.google.common.util.concurrent.ListenableFuture<GetRegisterLeasePResponse>	requestRegisterLease(GetRegisterLeasePRequest request) Requests a lease for registration

Methods inherited from class io.grpc.stub.AbstractFutureStub

newStub, newStub

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 BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub build(io.grpc.Channel channel,
                                                                                io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceFutureStub>

blockHeartbeat

public com.google.common.util.concurrent.ListenableFuture<BlockHeartbeatPResponse> blockHeartbeat(BlockHeartbeatPRequest request)

 Periodic block worker heartbeat returns an optional command for the block worker to execute.
 

commitBlock

public com.google.common.util.concurrent.ListenableFuture<CommitBlockPResponse> commitBlock(CommitBlockPRequest request)

 Marks the given block as committed.
 

getWorkerId

public com.google.common.util.concurrent.ListenableFuture<GetWorkerIdPResponse> getWorkerId(GetWorkerIdPRequest request)

 Returns a worker id for the given network address.
 

notifyWorkerId

public com.google.common.util.concurrent.ListenableFuture<NotifyWorkerIdPResponse> notifyWorkerId(NotifyWorkerIdPRequest request)

 Notify all masters about the worker ID.
 

registerWorker

public com.google.common.util.concurrent.ListenableFuture<RegisterWorkerPResponse> registerWorker(RegisterWorkerPRequest request)

 Registers a worker.
 

requestRegisterLease

public com.google.common.util.concurrent.ListenableFuture<GetRegisterLeasePResponse> requestRegisterLease(GetRegisterLeasePRequest request)

 Requests a lease for registration