alluxio.grpc

Interface BlockMasterClientServiceGrpc.AsyncService

All Known Implementing Classes:

BlockMasterClientServiceGrpc.BlockMasterClientServiceImplBase, BlockMasterClientServiceHandler

Enclosing class:

BlockMasterClientServiceGrpc

public static interface BlockMasterClientServiceGrpc.AsyncService

 This interface contains block master service endpoints for Alluxio clients.
 

Method Summary

Modifier and Type	Method and Description
default void	decommissionWorker(DecommissionWorkerPOptions request, io.grpc.stub.StreamObserver<DecommissionWorkerPResponse> responseObserver) Decommission the specific worker from Alluxio.
default void	getBlockInfo(GetBlockInfoPRequest request, io.grpc.stub.StreamObserver<GetBlockInfoPResponse> responseObserver) Returns the block information for the given block id.
default void	getBlockMasterInfo(GetBlockMasterInfoPOptions request, io.grpc.stub.StreamObserver<GetBlockMasterInfoPResponse> responseObserver) Returns block master information.
default void	getCapacityBytes(GetCapacityBytesPOptions request, io.grpc.stub.StreamObserver<GetCapacityBytesPResponse> responseObserver) Returns the capacity (in bytes).
default void	getLostWorkerList(GetWorkerInfoListPOptions request, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information.
default void	getUsedBytes(GetUsedBytesPOptions request, io.grpc.stub.StreamObserver<GetUsedBytesPResponse> responseObserver) Returns the used storage (in bytes).
default void	getWorkerInfoList(GetWorkerInfoListPOptions request, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information.
default void	getWorkerLostStorage(GetWorkerLostStoragePOptions request, io.grpc.stub.StreamObserver<GetWorkerLostStoragePResponse> responseObserver) Returns a list of worker lost storage information
default void	getWorkerReport(GetWorkerReportPOptions request, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information for report CLI.
default void	removeDisabledWorker(RemoveDisabledWorkerPOptions request, 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.

Method Detail

getBlockInfo

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

 Returns the block information for the given block id.
 

getBlockMasterInfo

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

 Returns block master information.
 

getCapacityBytes

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

 Returns the capacity (in bytes).
 

getUsedBytes

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

 Returns the used storage (in bytes).
 

getWorkerInfoList

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

 Returns a list of workers information.
 

getLostWorkerList

default void getLostWorkerList(GetWorkerInfoListPOptions request,
                               io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver)

 Returns a list of workers information.
 

removeDisabledWorker

default void removeDisabledWorker(RemoveDisabledWorkerPOptions request,
                                  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.
 

getWorkerReport

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

 Returns a list of workers information for report CLI.
 

getWorkerLostStorage

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

 Returns a list of worker lost storage information
 

decommissionWorker

default void decommissionWorker(DecommissionWorkerPOptions request,
                                io.grpc.stub.StreamObserver<DecommissionWorkerPResponse> responseObserver)

  Decommission the specific worker from Alluxio.