alluxio.grpc

Class BlockWorkerGrpc.BlockWorkerStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<BlockWorkerGrpc.BlockWorkerStub>

alluxio.grpc.BlockWorkerGrpc.BlockWorkerStub

Enclosing class:

BlockWorkerGrpc

public static final class BlockWorkerGrpc.BlockWorkerStub
extends io.grpc.stub.AbstractAsyncStub<BlockWorkerGrpc.BlockWorkerStub>

 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
void	asyncCache(AsyncCacheRequest request, io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)
protected BlockWorkerGrpc.BlockWorkerStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	cache(CacheRequest request, io.grpc.stub.StreamObserver<CacheResponse> responseObserver)
void	clearMetrics(ClearMetricsRequest request, io.grpc.stub.StreamObserver<ClearMetricsResponse> responseObserver) TODO(lu) Move to metrics worker
io.grpc.stub.StreamObserver<CreateLocalBlockRequest>	createLocalBlock(io.grpc.stub.StreamObserver<CreateLocalBlockResponse> responseObserver) Replaces ShortCircuitBlockWriteHandler.
void	freeWorker(FreeWorkerRequest request, io.grpc.stub.StreamObserver<FreeWorkerResponse> responseObserver)
void	load(LoadRequest request, io.grpc.stub.StreamObserver<LoadResponse> responseObserver)
void	moveBlock(MoveBlockRequest request, io.grpc.stub.StreamObserver<MoveBlockResponse> responseObserver)
io.grpc.stub.StreamObserver<OpenLocalBlockRequest>	openLocalBlock(io.grpc.stub.StreamObserver<OpenLocalBlockResponse> responseObserver) Replaces ShortCircuitBlockReadHandler.
io.grpc.stub.StreamObserver<ReadRequest>	readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
void	removeBlock(RemoveBlockRequest request, io.grpc.stub.StreamObserver<RemoveBlockResponse> responseObserver)
io.grpc.stub.StreamObserver<WriteRequest>	writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

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

Specified by:

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

readBlock

public io.grpc.stub.StreamObserver<ReadRequest> readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)

writeBlock

public io.grpc.stub.StreamObserver<WriteRequest> writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)

openLocalBlock

public io.grpc.stub.StreamObserver<OpenLocalBlockRequest> openLocalBlock(io.grpc.stub.StreamObserver<OpenLocalBlockResponse> responseObserver)

 Replaces ShortCircuitBlockReadHandler.
 

createLocalBlock

public io.grpc.stub.StreamObserver<CreateLocalBlockRequest> createLocalBlock(io.grpc.stub.StreamObserver<CreateLocalBlockResponse> responseObserver)

 Replaces ShortCircuitBlockWriteHandler.
 

asyncCache

public void asyncCache(AsyncCacheRequest request,
                       io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)

cache

public void cache(CacheRequest request,
                  io.grpc.stub.StreamObserver<CacheResponse> responseObserver)

load

public void load(LoadRequest request,
                 io.grpc.stub.StreamObserver<LoadResponse> responseObserver)

removeBlock

public void removeBlock(RemoveBlockRequest request,
                        io.grpc.stub.StreamObserver<RemoveBlockResponse> responseObserver)

moveBlock

public void moveBlock(MoveBlockRequest request,
                      io.grpc.stub.StreamObserver<MoveBlockResponse> responseObserver)

clearMetrics

public void clearMetrics(ClearMetricsRequest request,
                         io.grpc.stub.StreamObserver<ClearMetricsResponse> responseObserver)

 TODO(lu) Move to metrics worker
 

freeWorker

public void freeWorker(FreeWorkerRequest request,
                       io.grpc.stub.StreamObserver<FreeWorkerResponse> responseObserver)