@InterfaceStability.Evolving public interface RpcEngine
Modifier and Type | Method and Description |
---|---|
ProtocolProxy<ProtocolMetaInfoPB> |
getProtocolMetaInfoProxy(Client.ConnectionId connId,
Configuration conf,
SocketFactory factory)
Returns a proxy for ProtocolMetaInfoPB, which uses the given connection
id.
|
<T> ProtocolProxy<T> |
getProxy(Class<T> protocol,
long clientVersion,
InetSocketAddress addr,
UserGroupInformation ticket,
Configuration conf,
SocketFactory factory,
int rpcTimeout,
RetryPolicy connectionRetryPolicy)
Construct a client-side proxy object.
|
RPC.Server |
getServer(Class<?> protocol,
Object instance,
String bindAddress,
int port,
int numHandlers,
int numReaders,
int queueSizePerHandler,
boolean verbose,
Configuration conf,
SecretManager<? extends TokenIdentifier> secretManager,
String portRangeConfig)
Construct a server for a protocol implementation instance.
|
<T> ProtocolProxy<T> getProxy(Class<T> protocol, long clientVersion, InetSocketAddress addr, UserGroupInformation ticket, Configuration conf, SocketFactory factory, int rpcTimeout, RetryPolicy connectionRetryPolicy) throws IOException
T
- IOException
RPC.Server getServer(Class<?> protocol, Object instance, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, Configuration conf, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig) throws IOException
protocol
- the class of protocol to useinstance
- the instance of protocol whose methods will be calledconf
- the configuration to usebindAddress
- the address to bind on to listen for connectionport
- the port to listen for connections onnumHandlers
- the number of method handler threads to runnumReaders
- the number of reader threads to runqueueSizePerHandler
- the size of the queue per hander threadverbose
- whether each call should be loggedsecretManager
- The secret manager to use to validate incoming requests.portRangeConfig
- A config parameter that can be used to restrict
the range of ports used when port is 0 (an ephemeral port)IOException
- on any errorProtocolProxy<ProtocolMetaInfoPB> getProtocolMetaInfoProxy(Client.ConnectionId connId, Configuration conf, SocketFactory factory) throws IOException
connId,
- ConnectionId to be used for the proxy.conf,
- Configuration.factory,
- Socket factory.IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.