Struct RpcServer 

pub struct RpcServer { /* private fields */ }

Available on crate feature server only.

Convenient type alias for ZusServerManager

This is the main RPC server type for hosting services.

Example

use zus_rs::{RpcServer, prelude::*};
use bytes::Bytes;
use std::sync::Arc;

struct MyService;

#[async_trait]
impl Service for MyService {
    fn service_name(&self) -> &str { "MyService" }

    async fn do_work(
        &self,
        method: &str,
        params: Bytes,
        _ctx: zus_rpc_server::RequestContext,
    ) -> zus_common::Result<Bytes> {
        Ok(params)
    }
}

let mut server = RpcServer::new("0.0.0.0".to_string(), 9527);
server.register_service(Arc::new(MyService));
server.start().await?;

ZUS Server Manager (replacing Java’s ZusServerManager)

Implementations

impl ZusServerManager

pub fn new(address: String, port: u16) -> ZusServerManager

pub fn with_max_connections(self, max: usize) -> ZusServerManager

pub fn register_service(&mut self, service: Arc<dyn Service>)

pub fn with_zoo_client(self, zoo_client: Arc<ZusZooClient>) -> ZusServerManager

pub fn get_statistics(&self, service_name: &str) -> Option<ServiceStatistics>

Get statistics for a specific service

pub fn get_all_statistics(&self) -> HashMap<String, ServiceStatistics>

Get statistics for all registered services

pub fn reset_statistics(&self, service_name: &str)

Reset statistics for a specific service

pub fn reset_all_statistics(&self)

Reset statistics for all services

pub async fn start(self) -> Result<(), ZusError>

Start the server