alluxio.grpc

Class BlockWorkerGrpc

java.lang.Object

alluxio.grpc.BlockWorkerGrpc

@Generated(value="by gRPC proto compiler (version 1.37.0)",
           comments="Source: grpc/block_worker.proto")
public final class BlockWorkerGrpc
extends Object

 The block worker service
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockWorkerGrpc.BlockWorkerBlockingStub The block worker service
static class	BlockWorkerGrpc.BlockWorkerFutureStub The block worker service
static class	BlockWorkerGrpc.BlockWorkerImplBase The block worker service
static class	BlockWorkerGrpc.BlockWorkerStub The block worker service

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME

Method Summary

Modifier and Type	Method and Description
static io.grpc.MethodDescriptor<AsyncCacheRequest,AsyncCacheResponse>	getAsyncCacheMethod()
static io.grpc.MethodDescriptor<CacheRequest,CacheResponse>	getCacheMethod()
static io.grpc.MethodDescriptor<ClearMetricsRequest,ClearMetricsResponse>	getClearMetricsMethod()
static io.grpc.MethodDescriptor<CreateLocalBlockRequest,CreateLocalBlockResponse>	getCreateLocalBlockMethod()
static io.grpc.MethodDescriptor<MoveBlockRequest,MoveBlockResponse>	getMoveBlockMethod()
static io.grpc.MethodDescriptor<OpenLocalBlockRequest,OpenLocalBlockResponse>	getOpenLocalBlockMethod()
static io.grpc.MethodDescriptor<ReadRequest,ReadResponse>	getReadBlockMethod()
static io.grpc.MethodDescriptor<RemoveBlockRequest,RemoveBlockResponse>	getRemoveBlockMethod()
static io.grpc.ServiceDescriptor	getServiceDescriptor()
static io.grpc.MethodDescriptor<WriteRequest,WriteResponse>	getWriteBlockMethod()
static BlockWorkerGrpc.BlockWorkerBlockingStub	newBlockingStub(io.grpc.Channel channel) Creates a new blocking-style stub that supports unary and streaming output calls on the service
static BlockWorkerGrpc.BlockWorkerFutureStub	newFutureStub(io.grpc.Channel channel) Creates a new ListenableFuture-style stub that supports unary calls on the service
static BlockWorkerGrpc.BlockWorkerStub	newStub(io.grpc.Channel channel) Creates a new async stub that supports all call types for the service

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

Constant Field Values

Method Detail

getReadBlockMethod

public static io.grpc.MethodDescriptor<ReadRequest,ReadResponse> getReadBlockMethod()

getWriteBlockMethod

public static io.grpc.MethodDescriptor<WriteRequest,WriteResponse> getWriteBlockMethod()

getOpenLocalBlockMethod

public static io.grpc.MethodDescriptor<OpenLocalBlockRequest,OpenLocalBlockResponse> getOpenLocalBlockMethod()

getCreateLocalBlockMethod

public static io.grpc.MethodDescriptor<CreateLocalBlockRequest,CreateLocalBlockResponse> getCreateLocalBlockMethod()

getAsyncCacheMethod

public static io.grpc.MethodDescriptor<AsyncCacheRequest,AsyncCacheResponse> getAsyncCacheMethod()

getCacheMethod

public static io.grpc.MethodDescriptor<CacheRequest,CacheResponse> getCacheMethod()

getRemoveBlockMethod

public static io.grpc.MethodDescriptor<RemoveBlockRequest,RemoveBlockResponse> getRemoveBlockMethod()

getMoveBlockMethod

public static io.grpc.MethodDescriptor<MoveBlockRequest,MoveBlockResponse> getMoveBlockMethod()

getClearMetricsMethod

public static io.grpc.MethodDescriptor<ClearMetricsRequest,ClearMetricsResponse> getClearMetricsMethod()

newStub

public static BlockWorkerGrpc.BlockWorkerStub newStub(io.grpc.Channel channel)

Creates a new async stub that supports all call types for the service

newBlockingStub

public static BlockWorkerGrpc.BlockWorkerBlockingStub newBlockingStub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

newFutureStub

public static BlockWorkerGrpc.BlockWorkerFutureStub newFutureStub(io.grpc.Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

getServiceDescriptor

public static io.grpc.ServiceDescriptor getServiceDescriptor()