alluxio.master.block

Class BlockMasterWorkerServiceHandler

java.lang.Object

alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

alluxio.master.block.BlockMasterWorkerServiceHandler

All Implemented Interfaces:

BlockMasterWorkerServiceGrpc.AsyncService, io.grpc.BindableService

public final class BlockMasterWorkerServiceHandler
extends BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

This class is a gRPC handler for block master RPCs invoked by an Alluxio worker.

Constructor Summary

Constructors

Constructor and Description
BlockMasterWorkerServiceHandler(BlockMaster blockMaster) Creates a new instance of BlockMasterWorkerServiceHandler.

Method Summary

Modifier and Type	Method and Description
void	blockHeartbeat(BlockHeartbeatPRequest request, io.grpc.stub.StreamObserver<BlockHeartbeatPResponse> responseObserver) Periodic block worker heartbeat returns an optional command for the block worker to execute.
void	commitBlock(CommitBlockPRequest request, io.grpc.stub.StreamObserver<CommitBlockPResponse> responseObserver) Marks the given block as committed.
void	getWorkerId(GetWorkerIdPRequest request, io.grpc.stub.StreamObserver<GetWorkerIdPResponse> responseObserver) Returns a worker id for the given network address.
void	notifyWorkerId(NotifyWorkerIdPRequest request, io.grpc.stub.StreamObserver<NotifyWorkerIdPResponse> responseObserver) Notify all masters about the worker ID.
void	registerWorker(RegisterWorkerPRequest request, io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Registers a worker.
io.grpc.stub.StreamObserver<RegisterWorkerPRequest>	registerWorkerStream(io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver) Registers a worker in a streaming way
void	requestRegisterLease(GetRegisterLeasePRequest request, io.grpc.stub.StreamObserver<GetRegisterLeasePResponse> responseObserver) Requests a lease for registration

Methods inherited from class alluxio.grpc.BlockMasterWorkerServiceGrpc.BlockMasterWorkerServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockMasterWorkerServiceHandler

public BlockMasterWorkerServiceHandler(BlockMaster blockMaster)

Creates a new instance of BlockMasterWorkerServiceHandler.

Parameters:

blockMaster - the BlockMaster the handler uses internally

Method Detail

blockHeartbeat

public void blockHeartbeat(BlockHeartbeatPRequest request,
                           io.grpc.stub.StreamObserver<BlockHeartbeatPResponse> responseObserver)

Description copied from interface: BlockMasterWorkerServiceGrpc.AsyncService

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

commitBlock

public void commitBlock(CommitBlockPRequest request,
                        io.grpc.stub.StreamObserver<CommitBlockPResponse> responseObserver)

Description copied from interface: BlockMasterWorkerServiceGrpc.AsyncService

 Marks the given block as committed.
 

getWorkerId

public void getWorkerId(GetWorkerIdPRequest request,
                        io.grpc.stub.StreamObserver<GetWorkerIdPResponse> responseObserver)

Description copied from interface: BlockMasterWorkerServiceGrpc.AsyncService

 Returns a worker id for the given network address.
 

requestRegisterLease

public void requestRegisterLease(GetRegisterLeasePRequest request,
                                 io.grpc.stub.StreamObserver<GetRegisterLeasePResponse> responseObserver)

Description copied from interface: BlockMasterWorkerServiceGrpc.AsyncService

 Requests a lease for registration
 

registerWorker

public void registerWorker(RegisterWorkerPRequest request,
                           io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver)

Description copied from interface: BlockMasterWorkerServiceGrpc.AsyncService

 Registers a worker.
 

registerWorkerStream

public io.grpc.stub.StreamObserver<RegisterWorkerPRequest> registerWorkerStream(io.grpc.stub.StreamObserver<RegisterWorkerPResponse> responseObserver)

Description copied from interface: BlockMasterWorkerServiceGrpc.AsyncService

 Registers a worker in a streaming way
 

notifyWorkerId

public void notifyWorkerId(NotifyWorkerIdPRequest request,
                           io.grpc.stub.StreamObserver<NotifyWorkerIdPResponse> responseObserver)

Description copied from interface: BlockMasterWorkerServiceGrpc.AsyncService

 Notify all masters about the worker ID.