alluxio.master.block

Class BlockMasterClientServiceHandler

java.lang.Object

alluxio.grpc.BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

alluxio.master.block.BlockMasterClientServiceHandler

All Implemented Interfaces:

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	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	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	removeDecommissionedWorker(RemoveDecommissionedWorkerPOptions options, io.grpc.stub.StreamObserver<RemoveDecommissionedWorkerPResponse> 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 class: BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

 Returns the block information for the given block id.
 

Overrides:

getBlockInfo in class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

getBlockMasterInfo

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

Description copied from class: BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

 Returns block master information.
 

Overrides:

getBlockMasterInfo in class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

getCapacityBytes

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

Description copied from class: BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

 Returns the capacity (in bytes).
 

Overrides:

getCapacityBytes in class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

getUsedBytes

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

Description copied from class: BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

 Returns the used storage (in bytes).
 

Overrides:

getUsedBytes in class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

getWorkerInfoList

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

Description copied from class: BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

 Returns a list of workers information.
 

Overrides:

getWorkerInfoList in class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

removeDecommissionedWorker

public void removeDecommissionedWorker(RemoveDecommissionedWorkerPOptions options,
                                       io.grpc.stub.StreamObserver<RemoveDecommissionedWorkerPResponse> responseObserver)

Description copied from class: BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

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

Overrides:

removeDecommissionedWorker in class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

getWorkerReport

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

Description copied from class: BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

 Returns a list of workers information for report CLI.
 

Overrides:

getWorkerReport in class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

getWorkerLostStorage

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

Description copied from class: BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

 Returns a list of worker lost storage information
 

Overrides:

getWorkerLostStorage in class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase