alluxio.grpc

Class BlockMasterClientServiceGrpc.BlockMasterClientServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<BlockMasterClientServiceGrpc.BlockMasterClientServiceStub>

alluxio.grpc.BlockMasterClientServiceGrpc.BlockMasterClientServiceStub

Enclosing class:

BlockMasterClientServiceGrpc

public static final class BlockMasterClientServiceGrpc.BlockMasterClientServiceStub
extends io.grpc.stub.AbstractAsyncStub<BlockMasterClientServiceGrpc.BlockMasterClientServiceStub>

A stub to allow clients to do asynchronous rpc calls to service BlockMasterClientService.

 This interface contains block master service endpoints for Alluxio clients.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
protected BlockMasterClientServiceGrpc.BlockMasterClientServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	decommissionWorker(DecommissionWorkerPOptions request, 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 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	getLostWorkerList(GetWorkerInfoListPOptions request, io.grpc.stub.StreamObserver<GetWorkerInfoListPResponse> responseObserver) Returns a list of workers information.
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	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.

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected BlockMasterClientServiceGrpc.BlockMasterClientServiceStub build(io.grpc.Channel channel,
                                                                          io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<BlockMasterClientServiceGrpc.BlockMasterClientServiceStub>

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.
 

getLostWorkerList

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

 Returns a list of workers information.
 

removeDisabledWorker

public 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

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
 

decommissionWorker

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

  Decommission the specific worker from Alluxio.