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>

 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<CommitBlockInUfsPResponse>	commitBlockInUfs(CommitBlockInUfsPRequest request) Marks the given block as committed which resides in UFS.
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.
 

commitBlockInUfs

public com.google.common.util.concurrent.ListenableFuture<CommitBlockInUfsPResponse> commitBlockInUfs(CommitBlockInUfsPRequest request)

 Marks the given block as committed which resides in UFS.
 

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