Struct rpcx_server::Server

pub struct Server {
    pub addr: String,
    pub services: Arc<RwLock<HashMap<String, Box<RpcxFn>>>>,
    // some fields omitted
}

Fields

addr: String

services: Arc<RwLock<HashMap<String, Box<RpcxFn>>>>

Methods

impl Server

pub fn add_register_plugin(&mut self, p: &dyn RegisterPlugin)

pub fn add_connect_plugin(&mut self, p: &dyn ConnectPlugin)

impl Server

pub fn new(s: String, n: u32) -> Self

pub fn register_fn(
    &mut self,
    service_path: String,
    service_method: String,
    f: RpcxFn
)

pub fn get_fn(
    &self,
    service_path: String,
    service_method: String
) -> Option<RpcxFn>

pub fn start_with_listener(&self, listener: TcpListener) -> Result<()>

pub fn start(&mut self) -> Result<()>

pub fn close(&self)