alluxio.grpc

Class BlockWorkerGrpc.BlockWorkerBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<BlockWorkerGrpc.BlockWorkerBlockingStub>

alluxio.grpc.BlockWorkerGrpc.BlockWorkerBlockingStub

Enclosing class:

BlockWorkerGrpc

public static final class BlockWorkerGrpc.BlockWorkerBlockingStub
extends io.grpc.stub.AbstractBlockingStub<BlockWorkerGrpc.BlockWorkerBlockingStub>

 The block worker service
 

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
AsyncCacheResponse	asyncCache(AsyncCacheRequest request)
protected BlockWorkerGrpc.BlockWorkerBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
CacheResponse	cache(CacheRequest request)
ClearMetricsResponse	clearMetrics(ClearMetricsRequest request) TODO(lu) Move to metrics worker
FreeWorkerResponse	freeWorker(FreeWorkerRequest request)
LoadResponse	load(LoadRequest request)
MoveBlockResponse	moveBlock(MoveBlockRequest request)
RemoveBlockResponse	removeBlock(RemoveBlockRequest request)

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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

Specified by:

build in class io.grpc.stub.AbstractStub<BlockWorkerGrpc.BlockWorkerBlockingStub>

asyncCache

public AsyncCacheResponse asyncCache(AsyncCacheRequest request)

cache

public CacheResponse cache(CacheRequest request)

load

public LoadResponse load(LoadRequest request)

removeBlock

public RemoveBlockResponse removeBlock(RemoveBlockRequest request)

moveBlock

public MoveBlockResponse moveBlock(MoveBlockRequest request)

clearMetrics

public ClearMetricsResponse clearMetrics(ClearMetricsRequest request)

 TODO(lu) Move to metrics worker
 

freeWorker

public FreeWorkerResponse freeWorker(FreeWorkerRequest request)