@InterfaceAudience.Private
public interface RpcServerInterface
Modifier and Type | Method and Description |
---|---|
Pair<com.google.protobuf.Message,CellScanner> |
call(com.google.protobuf.BlockingService service,
com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status) |
InetSocketAddress |
getListenerAddress() |
MetricsHBaseServer |
getMetrics()
Returns the metrics instance for reporting RPC call statistics
|
void |
join() |
void |
openServer() |
void |
refreshAuthManager(org.apache.hadoop.security.authorize.PolicyProvider pp)
Refresh autentication manager policy.
|
void |
setErrorHandler(HBaseRPCErrorHandler handler) |
void |
setQosFunction(com.google.common.base.Function<Pair<RPCProtos.RequestHeader,com.google.protobuf.Message>,Integer> newFunc) |
void |
setSocketSendBufSize(int size) |
void |
start() |
void |
startThreads() |
void |
stop() |
void setSocketSendBufSize(int size)
void start()
void stop()
void join() throws InterruptedException
InterruptedException
InetSocketAddress getListenerAddress()
Pair<com.google.protobuf.Message,CellScanner> call(com.google.protobuf.BlockingService service, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status) throws IOException, com.google.protobuf.ServiceException
IOException
com.google.protobuf.ServiceException
void setErrorHandler(HBaseRPCErrorHandler handler)
void openServer()
void startThreads()
MetricsHBaseServer getMetrics()
void setQosFunction(com.google.common.base.Function<Pair<RPCProtos.RequestHeader,com.google.protobuf.Message>,Integer> newFunc)
void refreshAuthManager(org.apache.hadoop.security.authorize.PolicyProvider pp)
pp
- Copyright © 2013 The Apache Software Foundation. All rights reserved.