alluxio.master.block

Class BlockMasterClientServiceHandler

java.lang.Object

alluxio.grpc.BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

alluxio.master.block.BlockMasterClientServiceHandler

All Implemented Interfaces:

BlockMasterClientServiceGrpc.AsyncService, io.grpc.BindableService

public final class BlockMasterClientServiceHandler
extends BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	decommissionWorker(DecommissionWorkerPOptions options, io.grpc.stub.StreamObserver<DecommissionWorkerPResponse> responseObserver) Decommission the specific worker from Alluxio.
void	getBlockInfo(GetBlockInfoPRequest request, io.grpc.stub.StreamObserver<GetBlockInfoPResponse> responseObserver) Returns the block information for the given block id.
void	getBlockMasterInfo(GetBlockMasterInfoPOptions options, io.grpc.stub.StreamObserver<GetBlockMasterInfoPResponse> responseObserver) Returns block master information.
void	getCapacityBytes(GetCapacityBytesPOptions options, io.grpc.stub.StreamObserver<GetCapacityBytesPResponse> responseObserver) Returns the capacity (in bytes).
void	getLostWorkerList(GetWorkerInfoListPOptions options, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information.
void	getUsedBytes(GetUsedBytesPOptions options, io.grpc.stub.StreamObserver<GetUsedBytesPResponse> responseObserver) Returns the used storage (in bytes).
void	getWorkerInfoList(GetWorkerInfoListPOptions options, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information.
void	getWorkerLostStorage(GetWorkerLostStoragePOptions options, io.grpc.stub.StreamObserver<GetWorkerLostStoragePResponse> responseObserver) Returns a list of worker lost storage information
void	getWorkerReport(GetWorkerReportPOptions options, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information for report CLI.
void	removeDisabledWorker(RemoveDisabledWorkerPOptions options, io.grpc.stub.StreamObserver<RemoveDisabledWorkerPResponse> responseObserver) If target worker is in the decommissioned worker set, return true, remove target worker from decommissioned worker set; else, return false.

Methods inherited from class alluxio.grpc.BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockMasterClientServiceHandler

public BlockMasterClientServiceHandler(BlockMaster blockMaster)

Creates a new instance of BlockMasterClientServiceHandler.

Parameters:

blockMaster - the BlockMaster the handler uses internally

Method Detail

getBlockInfo

public void getBlockInfo(GetBlockInfoPRequest request,
                         io.grpc.stub.StreamObserver<GetBlockInfoPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 Returns the block information for the given block id.
 

getBlockMasterInfo

public void getBlockMasterInfo(GetBlockMasterInfoPOptions options,
                               io.grpc.stub.StreamObserver<GetBlockMasterInfoPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 Returns block master information.
 

getCapacityBytes

public void getCapacityBytes(GetCapacityBytesPOptions options,
                             io.grpc.stub.StreamObserver<GetCapacityBytesPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 Returns the capacity (in bytes).
 

getUsedBytes

public void getUsedBytes(GetUsedBytesPOptions options,
                         io.grpc.stub.StreamObserver<GetUsedBytesPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 Returns the used storage (in bytes).
 

getWorkerInfoList

public void getWorkerInfoList(GetWorkerInfoListPOptions options,
                              io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 Returns a list of workers information.
 

getLostWorkerList

public void getLostWorkerList(GetWorkerInfoListPOptions options,
                              io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 Returns a list of workers information.
 

removeDisabledWorker

public void removeDisabledWorker(RemoveDisabledWorkerPOptions options,
                                 io.grpc.stub.StreamObserver<RemoveDisabledWorkerPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 If target worker is in the decommissioned worker set,
 return true, remove target worker from decommissioned worker set; else, return false.
 

getWorkerReport

public void getWorkerReport(GetWorkerReportPOptions options,
                            io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 Returns a list of workers information for report CLI.
 

getWorkerLostStorage

public void getWorkerLostStorage(GetWorkerLostStoragePOptions options,
                                 io.grpc.stub.StreamObserver<GetWorkerLostStoragePResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

 Returns a list of worker lost storage information
 

decommissionWorker

public void decommissionWorker(DecommissionWorkerPOptions options,
                               io.grpc.stub.StreamObserver<DecommissionWorkerPResponse> responseObserver)

Description copied from interface: BlockMasterClientServiceGrpc.AsyncService

  Decommission the specific worker from Alluxio.