alluxio.worker.grpc

Class BlockWorkerClientServiceHandler

java.lang.Object

alluxio.grpc.BlockWorkerGrpc.BlockWorkerImplBase

alluxio.worker.grpc.BlockWorkerClientServiceHandler

All Implemented Interfaces:

io.grpc.BindableService

public class BlockWorkerClientServiceHandler
extends BlockWorkerGrpc.BlockWorkerImplBase

Server side implementation of the gRPC BlockWorker interface.

Constructor Summary

Constructors

Constructor and Description
BlockWorkerClientServiceHandler(WorkerProcess workerProcess, FileSystemContext fsContext, boolean domainSocketEnabled) Creates a new implementation of gRPC BlockWorker interface.

Method Summary

Modifier and Type	Method and Description
void	asyncCache(AsyncCacheRequest request, io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)
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.
Map<io.grpc.MethodDescriptor,io.grpc.MethodDescriptor>	getOverriddenMethodDescriptors()
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 alluxio.grpc.BlockWorkerGrpc.BlockWorkerImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockWorkerClientServiceHandler

public BlockWorkerClientServiceHandler(WorkerProcess workerProcess,
                                       FileSystemContext fsContext,
                                       boolean domainSocketEnabled)

Creates a new implementation of gRPC BlockWorker interface.

Parameters:

workerProcess - the worker process

fsContext - context used to read blocks

domainSocketEnabled - is using domain sockets

Method Detail

getOverriddenMethodDescriptors

public Map<io.grpc.MethodDescriptor,io.grpc.MethodDescriptor> getOverriddenMethodDescriptors()

Returns:

a map of gRPC methods with overridden descriptors

readBlock

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

Overrides:

readBlock in class BlockWorkerGrpc.BlockWorkerImplBase

writeBlock

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

Overrides:

writeBlock in class BlockWorkerGrpc.BlockWorkerImplBase

openLocalBlock

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

Description copied from class: BlockWorkerGrpc.BlockWorkerImplBase

 Replaces ShortCircuitBlockReadHandler.
 

Overrides:

openLocalBlock in class BlockWorkerGrpc.BlockWorkerImplBase

createLocalBlock

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

Description copied from class: BlockWorkerGrpc.BlockWorkerImplBase

 Replaces ShortCircuitBlockWriteHandler.
 

Overrides:

createLocalBlock in class BlockWorkerGrpc.BlockWorkerImplBase

asyncCache

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

Overrides:

asyncCache in class BlockWorkerGrpc.BlockWorkerImplBase

cache

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

Overrides:

cache in class BlockWorkerGrpc.BlockWorkerImplBase

removeBlock

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

Overrides:

removeBlock in class BlockWorkerGrpc.BlockWorkerImplBase

moveBlock

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

Overrides:

moveBlock in class BlockWorkerGrpc.BlockWorkerImplBase

clearMetrics

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

Description copied from class: BlockWorkerGrpc.BlockWorkerImplBase

 TODO(lu) Move to metrics worker
 

Overrides:

clearMetrics in class BlockWorkerGrpc.BlockWorkerImplBase