public static final class BlockWorkerGrpc.BlockWorkerStub extends io.grpc.stub.AbstractAsyncStub<BlockWorkerGrpc.BlockWorkerStub>
The block worker service
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 |
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) |
protected BlockWorkerGrpc.BlockWorkerStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<BlockWorkerGrpc.BlockWorkerStub>
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
Copyright © 2023. All Rights Reserved.