public interface RpcServerInterface
Modifier and Type | Method and Description |
---|---|
void |
addCallSize(long diff)
Add/subtract from the current size of all outstanding calls.
|
<any> |
call(BlockingService service,
MethodDescriptor md,
Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status)
Deprecated.
As of release 1.3, this will be removed in HBase 3.0
|
<any> |
call(BlockingService service,
MethodDescriptor md,
Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status,
long startTime,
int timeout)
Deprecated.
As of release 2.0, this will be removed in HBase 3.0
|
<any> |
call(RpcCall call,
MonitoredRPCHandler status) |
HBaseRPCErrorHandler |
getErrorHandler() |
java.net.InetSocketAddress |
getListenerAddress() |
MetricsHBaseServer |
getMetrics()
Returns the metrics instance for reporting RPC call statistics
|
RpcScheduler |
getScheduler() |
boolean |
isStarted() |
void |
join() |
void |
refreshAuthManager(PolicyProvider pp)
Refresh authentication manager policy.
|
void |
setErrorHandler(HBaseRPCErrorHandler handler) |
void |
setRsRpcServices(RSRpcServices rsRpcServices) |
void |
setSocketSendBufSize(int size) |
void |
start() |
void |
stop() |
void start()
boolean isStarted()
void stop()
void join() throws java.lang.InterruptedException
java.lang.InterruptedException
void setSocketSendBufSize(int size)
java.net.InetSocketAddress getListenerAddress()
@Deprecated <any> call(BlockingService service, MethodDescriptor md, Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status) throws java.io.IOException
java.io.IOException
@Deprecated <any> call(BlockingService service, MethodDescriptor md, Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status, long startTime, int timeout) throws java.io.IOException
java.io.IOException
<any> call(RpcCall call, MonitoredRPCHandler status) throws java.io.IOException
java.io.IOException
void setErrorHandler(HBaseRPCErrorHandler handler)
HBaseRPCErrorHandler getErrorHandler()
MetricsHBaseServer getMetrics()
void addCallSize(long diff)
diff
- Change (plus or minus)void refreshAuthManager(PolicyProvider pp)
pp
- RpcScheduler getScheduler()
void setRsRpcServices(RSRpcServices rsRpcServices)