alluxio.grpc

Class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

java.lang.Object

alluxio.grpc.BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

BlockMasterClientServiceHandler

Enclosing class:

BlockMasterClientServiceGrpc

public abstract static class BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase
extends Object
implements io.grpc.BindableService

 This interface contains block master service endpoints for Alluxio clients.
 

Constructor Summary

Constructors

Constructor and Description
BlockMasterClientServiceImplBase()

Method Summary

Modifier and Type	Method and Description
io.grpc.ServerServiceDefinition	bindService()
void	getBlockInfo(GetBlockInfoPRequest request, io.grpc.stub.StreamObserver<GetBlockInfoPResponse> responseObserver) Returns the block information for the given block id.
void	getBlockMasterInfo(GetBlockMasterInfoPOptions request, io.grpc.stub.StreamObserver<GetBlockMasterInfoPResponse> responseObserver) Returns block master information.
void	getCapacityBytes(GetCapacityBytesPOptions request, io.grpc.stub.StreamObserver<GetCapacityBytesPResponse> responseObserver) Returns the capacity (in bytes).
void	getUsedBytes(GetUsedBytesPOptions request, io.grpc.stub.StreamObserver<GetUsedBytesPResponse> responseObserver) Returns the used storage (in bytes).
void	getWorkerInfoList(GetWorkerInfoListPOptions request, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information.
void	getWorkerLostStorage(GetWorkerLostStoragePOptions request, io.grpc.stub.StreamObserver<GetWorkerLostStoragePResponse> responseObserver) Returns a list of worker lost storage information
void	getWorkerReport(GetWorkerReportPOptions request, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information for report CLI.
void	removeDecommissionedWorker(RemoveDecommissionedWorkerPOptions request, 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 java.lang.Object

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

Constructor Detail

BlockMasterClientServiceImplBase

public BlockMasterClientServiceImplBase()

Method Detail

getBlockInfo

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

 Returns the block information for the given block id.
 

getBlockMasterInfo

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

 Returns block master information.
 

getCapacityBytes

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

 Returns the capacity (in bytes).
 

getUsedBytes

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

 Returns the used storage (in bytes).
 

getWorkerInfoList

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

 Returns a list of workers information.
 

removeDecommissionedWorker

public void removeDecommissionedWorker(RemoveDecommissionedWorkerPOptions request,
                                       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.
 

getWorkerReport

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

 Returns a list of workers information for report CLI.
 

getWorkerLostStorage

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

 Returns a list of worker lost storage information
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService