Struct station::rpc::RpcServer

pub struct RpcServer { /* fields omitted */ }

The RPC server listens for incoming messages of type T, processes them, and returns a result containing bytes that can be deserialized to the type U.

Implementations

impl RpcServer

pub fn with_tcp_port<T, U>(
    name: &'static str,
    port: u16,
    callback: Box<dyn Send + Fn(T) -> Result<U, String>>
) -> RpcServer where
    T: Debug + DeserializeOwned + Serialize + 'static,
    U: Debug + DeserializeOwned + Serialize + 'static, 

Create an RPC server bound to a TCP port.

Args:

• name: A name to refer to the RPC server.
• port: The TCP port to bind the server to
• callback: The function to call on incoming data.

pub fn with_unix_socket<T, U>(
    name: &'static str,
    path: &str,
    callback: Box<dyn Send + Fn(T) -> Result<U, String>>
) -> RpcServer where
    T: Debug + DeserializeOwned + Serialize + 'static,
    U: Debug + DeserializeOwned + Serialize + 'static, 

Create an RPC server bound to a Unix socket.

Args:

• name: A name to refer to the RPC server.
• path: The unix socket path to bind the server to
• callback: The function to call on incoming data.

pub fn is_running(&self) -> bool

Check if the RPC server is running.

pub fn stop(&mut self)

Stop the RPC server.

Trait Implementations

impl Drop for RpcServer

fn drop(&mut self)

Executes the destructor for this type.