alluxio.grpc

Class BlockWorkerGrpc.BlockWorkerImplBase

java.lang.Object

alluxio.grpc.BlockWorkerGrpc.BlockWorkerImplBase

All Implemented Interfaces:

io.grpc.BindableService

Direct Known Subclasses:

BlockWorkerClientServiceHandler

Enclosing class:

BlockWorkerGrpc

public abstract static class BlockWorkerGrpc.BlockWorkerImplBase
extends Object
implements io.grpc.BindableService

 The block worker service
 

Constructor Summary

Constructors

Constructor and Description
BlockWorkerImplBase()

Method Summary

Modifier and Type	Method and Description
void	asyncCache(AsyncCacheRequest request, io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)
io.grpc.ServerServiceDefinition	bindService()
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	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 java.lang.Object

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

Constructor Detail

BlockWorkerImplBase

public BlockWorkerImplBase()

Method Detail

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)

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
 

bindService

public final io.grpc.ServerServiceDefinition bindService()

Specified by:

bindService in interface io.grpc.BindableService