Struct rpcx::Server

pub struct Server {
    pub addr: String,
    pub services: Arc<RwLock<HashMap<String, Box<fn(&[u8], SerializeType) -> Result<Vec<u8>, Error>>, RandomState>>>,
    // some fields omitted
}

Fields

addr: String

services: Arc<RwLock<HashMap<String, Box<fn(&[u8], SerializeType) -> Result<Vec<u8>, Error>>, RandomState>>>

Methods

impl Server

pub fn add_register_plugin(
    &mut self,
    p: Box<dyn RegisterPlugin + 'static + Sync + Send>
)

pub fn add_connect_plugin(
    &mut self,
    p: Box<dyn ConnectPlugin + 'static + Sync + Send>
)

impl Server

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

pub fn register_fn(
    &mut self,
    service_path: String,
    service_method: String,
    meta: String,
    f: fn(&[u8], SerializeType) -> Result<Vec<u8>, Error>
)

pub fn get_fn(
    &self,
    service_path: String,
    service_method: String
) -> Option<fn(&[u8], SerializeType) -> Result<Vec<u8>, Error>>

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

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

pub fn close(&self)