public static final class BlockWorkerGrpc.BlockWorkerFutureStub extends io.grpc.stub.AbstractFutureStub<BlockWorkerGrpc.BlockWorkerFutureStub>
The block worker service
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<AsyncCacheResponse> |
asyncCache(AsyncCacheRequest request) |
protected BlockWorkerGrpc.BlockWorkerFutureStub |
build(io.grpc.Channel channel,
io.grpc.CallOptions callOptions) |
com.google.common.util.concurrent.ListenableFuture<ClearMetricsResponse> |
clearMetrics(ClearMetricsRequest request)
TODO(lu) Move to metrics worker
|
com.google.common.util.concurrent.ListenableFuture<MoveBlockResponse> |
moveBlock(MoveBlockRequest request) |
com.google.common.util.concurrent.ListenableFuture<RemoveBlockResponse> |
removeBlock(RemoveBlockRequest request) |
protected BlockWorkerGrpc.BlockWorkerFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
build
in class io.grpc.stub.AbstractStub<BlockWorkerGrpc.BlockWorkerFutureStub>
public com.google.common.util.concurrent.ListenableFuture<AsyncCacheResponse> asyncCache(AsyncCacheRequest request)
public com.google.common.util.concurrent.ListenableFuture<RemoveBlockResponse> removeBlock(RemoveBlockRequest request)
public com.google.common.util.concurrent.ListenableFuture<MoveBlockResponse> moveBlock(MoveBlockRequest request)
public com.google.common.util.concurrent.ListenableFuture<ClearMetricsResponse> clearMetrics(ClearMetricsRequest request)
TODO(lu) Move to metrics worker
Copyright © 2023. All Rights Reserved.