Struct RpcMgr 

pub struct RpcMgr { /* private fields */ }

Shared state, configuration, and data for all RPC sessions.

An RpcMgr knows how to listen for incoming RPC connections, and launch sessions based on them.

Implementations

impl RpcMgr

pub fn new<F>(make_session: F) -> Result<Arc<Self>, RpcMgrError>

where F: Fn(&RpcAuthentication) -> Arc<dyn Object> + Send + Sync + 'static,

Create a new RpcMgr.

pub fn register_rpc_methods<I>(&self, entries: I)

where I: IntoIterator<Item = InvokerEnt>,

Extend our method dispatch table with the method entries in entries.

Ignores any entries that

Panics

Panics if any entries are conflicting, according to the logic of DispatchTable::insert

pub fn with_dispatch_table<F, T>(&self, func: F) -> T

where F: FnOnce(&mut DispatchTable) -> T,

Run func with a mutable reference to our dispatch table as an argument.

Used to register additional methods.

pub fn new_connection( self: &Arc<Self>, require_auth: RpcAuth, ) -> Arc<Connection>

Start a new session based on this RpcMgr, with a given TorClient.

pub fn lookup_object( &self, id: &ObjectId, ) -> Result<(Arc<dyn Context>, Arc<dyn Object>), LookupError>

Look up an object in the context of this RpcMgr.

Some object identifiers exist in a manager-global context, so that they can be used outside of a single RPC session. This function looks up an object by such an identifier string. It returns an error if the identifier is invalid or the object does not exist.

Along with the object, this additionally returns the rpc::Context associated with the object. That context can be used to invoke any special methods on the object.