alluxio.grpc

Class BlockMasterClientServiceGrpc.BlockMasterClientServiceFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<BlockMasterClientServiceGrpc.BlockMasterClientServiceFutureStub>

alluxio.grpc.BlockMasterClientServiceGrpc.BlockMasterClientServiceFutureStub

Enclosing class:

BlockMasterClientServiceGrpc

public static final class BlockMasterClientServiceGrpc.BlockMasterClientServiceFutureStub
extends io.grpc.stub.AbstractFutureStub<BlockMasterClientServiceGrpc.BlockMasterClientServiceFutureStub>

A stub to allow clients to do ListenableFuture-style 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.BlockMasterClientServiceFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<DecommissionWorkerPResponse>	decommissionWorker(DecommissionWorkerPOptions request) Decommission the specific worker from Alluxio.
com.google.common.util.concurrent.ListenableFuture<GetBlockInfoPResponse>	getBlockInfo(GetBlockInfoPRequest request) Returns the block information for the given block id.
com.google.common.util.concurrent.ListenableFuture<GetBlockMasterInfoPResponse>	getBlockMasterInfo(GetBlockMasterInfoPOptions request) Returns block master information.
com.google.common.util.concurrent.ListenableFuture<GetCapacityBytesPResponse>	getCapacityBytes(GetCapacityBytesPOptions request) Returns the capacity (in bytes).
com.google.common.util.concurrent.ListenableFuture<GetWorkerInfoListPResponse>	getLostWorkerList(GetWorkerInfoListPOptions request) Returns a list of workers information.
com.google.common.util.concurrent.ListenableFuture<GetUsedBytesPResponse>	getUsedBytes(GetUsedBytesPOptions request) Returns the used storage (in bytes).
com.google.common.util.concurrent.ListenableFuture<GetWorkerInfoListPResponse>	getWorkerInfoList(GetWorkerInfoListPOptions request) Returns a list of workers information.
com.google.common.util.concurrent.ListenableFuture<GetWorkerLostStoragePResponse>	getWorkerLostStorage(GetWorkerLostStoragePOptions request) Returns a list of worker lost storage information
com.google.common.util.concurrent.ListenableFuture<GetWorkerInfoListPResponse>	getWorkerReport(GetWorkerReportPOptions request) Returns a list of workers information for report CLI.
com.google.common.util.concurrent.ListenableFuture<RemoveDisabledWorkerPResponse>	removeDisabledWorker(RemoveDisabledWorkerPOptions request) 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.AbstractFutureStub

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.BlockMasterClientServiceFutureStub build(io.grpc.Channel channel,
                                                                                io.grpc.CallOptions callOptions)

Specified by:

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

getBlockInfo

public com.google.common.util.concurrent.ListenableFuture<GetBlockInfoPResponse> getBlockInfo(GetBlockInfoPRequest request)

 Returns the block information for the given block id.
 

getBlockMasterInfo

public com.google.common.util.concurrent.ListenableFuture<GetBlockMasterInfoPResponse> getBlockMasterInfo(GetBlockMasterInfoPOptions request)

 Returns block master information.
 

getCapacityBytes

public com.google.common.util.concurrent.ListenableFuture<GetCapacityBytesPResponse> getCapacityBytes(GetCapacityBytesPOptions request)

 Returns the capacity (in bytes).
 

getUsedBytes

public com.google.common.util.concurrent.ListenableFuture<GetUsedBytesPResponse> getUsedBytes(GetUsedBytesPOptions request)

 Returns the used storage (in bytes).
 

getWorkerInfoList

public com.google.common.util.concurrent.ListenableFuture<GetWorkerInfoListPResponse> getWorkerInfoList(GetWorkerInfoListPOptions request)

 Returns a list of workers information.
 

getLostWorkerList

public com.google.common.util.concurrent.ListenableFuture<GetWorkerInfoListPResponse> getLostWorkerList(GetWorkerInfoListPOptions request)

 Returns a list of workers information.
 

removeDisabledWorker

public com.google.common.util.concurrent.ListenableFuture<RemoveDisabledWorkerPResponse> removeDisabledWorker(RemoveDisabledWorkerPOptions request)

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

getWorkerReport

public com.google.common.util.concurrent.ListenableFuture<GetWorkerInfoListPResponse> getWorkerReport(GetWorkerReportPOptions request)

 Returns a list of workers information for report CLI.
 

getWorkerLostStorage

public com.google.common.util.concurrent.ListenableFuture<GetWorkerLostStoragePResponse> getWorkerLostStorage(GetWorkerLostStoragePOptions request)

 Returns a list of worker lost storage information
 

decommissionWorker

public com.google.common.util.concurrent.ListenableFuture<DecommissionWorkerPResponse> decommissionWorker(DecommissionWorkerPOptions request)

  Decommission the specific worker from Alluxio.