Interface | Description |
---|---|
HBaseRPCErrorHandler |
An interface for calling out of RPC for error conditions.
|
MetricsHBaseServerSource | |
MetricsHBaseServerWrapper | |
PriorityFunction |
Function to figure priority of incoming request.
|
RpcCall |
Interface of all necessary to carry out a RPC method invocation on the server.
|
RpcCallback |
Denotes a callback action that has to be executed at the end of an Rpc Call.
|
RpcCallContext |
Interface of all necessary to carry out a RPC service invocation on the server.
|
RpcServer.CallCleanup | |
RpcServerInterface |
Class | Description |
---|---|
AdaptiveLifoCoDelCallQueue |
Adaptive LIFO blocking queue utilizing CoDel algorithm to prevent queue overloading.
|
BalancedQueueRpcExecutor |
An
RpcExecutor that will balance requests evenly across all its queues, but still remains
efficient with a single queue via an inlinable queue balancing mechanism. |
CallQueueInfo | |
CallRunner |
The request processing logic, which is usually executed in thread pools provided by an
RpcScheduler . |
EmptyServiceNameException | |
FastPathBalancedQueueRpcExecutor |
Balanced queue executor with a fastpath.
|
FifoRpcScheduler |
A very simple RpcScheduler} that serves incoming requests in order.
|
IntegrationTestRpcClient | |
MetricsHBaseServer | |
MetricsHBaseServerSourceFactory | |
MetricsHBaseServerWrapperImpl | |
NettyRpcFrameDecoder |
Decoder for extracting frame
|
NettyRpcServer |
An RPC server with Netty4 implementation.
|
RpcExecutor |
Runs the CallRunners passed here via
RpcExecutor.dispatch(CallRunner) . |
RpcExecutor.QueueBalancer | |
RpcScheduler |
An interface for RPC request scheduling algorithm.
|
RpcScheduler.Context |
Exposes runtime information of a
RpcServer that a RpcScheduler may need. |
RpcServer |
An RPC server that hosts protobuf described Services.
|
RpcServer.BlockingServiceAndInterface |
Datastructure for passing a
BlockingService and its associated class of
protobuf service interface. |
RpcServerFactory | |
RWQueueRpcExecutor |
RPC Executor that uses different queues for reads and writes.
|
SimpleRpcScheduler |
The default scheduler.
|
SimpleRpcServer |
The RPC server with native java NIO implementation deriving from Hadoop to
host protobuf described Services.
|
UnknownServiceException |
Annotation Type | Description |
---|---|
QosPriority |
Annotation which decorates RPC methods to denote the relative priority among other RPCs in the
same server.
|