public abstract static class BlockWorkerGrpc.BlockWorkerImplBase extends Object implements io.grpc.BindableService
The block worker service
Constructor and Description |
---|
BlockWorkerImplBase() |
Modifier and Type | Method and Description |
---|---|
void |
asyncCache(AsyncCacheRequest request,
io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver) |
io.grpc.ServerServiceDefinition |
bindService() |
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) |
public io.grpc.stub.StreamObserver<ReadRequest> readBlock(io.grpc.stub.StreamObserver<ReadResponse> responseObserver)
public io.grpc.stub.StreamObserver<WriteRequest> writeBlock(io.grpc.stub.StreamObserver<WriteResponse> responseObserver)
public io.grpc.stub.StreamObserver<OpenLocalBlockRequest> openLocalBlock(io.grpc.stub.StreamObserver<OpenLocalBlockResponse> responseObserver)
Replaces ShortCircuitBlockReadHandler.
public io.grpc.stub.StreamObserver<CreateLocalBlockRequest> createLocalBlock(io.grpc.stub.StreamObserver<CreateLocalBlockResponse> responseObserver)
Replaces ShortCircuitBlockWriteHandler.
public void asyncCache(AsyncCacheRequest request, io.grpc.stub.StreamObserver<AsyncCacheResponse> responseObserver)
public void removeBlock(RemoveBlockRequest request, io.grpc.stub.StreamObserver<RemoveBlockResponse> responseObserver)
public void moveBlock(MoveBlockRequest request, io.grpc.stub.StreamObserver<MoveBlockResponse> responseObserver)
public void clearMetrics(ClearMetricsRequest request, io.grpc.stub.StreamObserver<ClearMetricsResponse> responseObserver)
TODO(lu) Move to metrics worker
public final io.grpc.ServerServiceDefinition bindService()
bindService
in interface io.grpc.BindableService
Copyright © 2023. All Rights Reserved.