Struct RpcClient 

pub struct RpcClient { /* private fields */ }

Available on crate feature client only.

Convenient type alias for BaseRpcClient

This is the main RPC client type for making service calls.

Example

use zus_rs::RpcClient;

// Connect via TCP
let client = RpcClient::new("tcp://localhost:9527").await?;

// Or via ZooServer discovery
let client = RpcClient::new("zns://localhost:9528/zus/services/myservice/").await?;

Base RPC Client implementation

Implementations

impl BaseRpcClient

pub async fn new(server_path: &str) -> Result<BaseRpcClient, ZusError>

Create client with default configuration (no pooling)

Example

let client = BaseRpcClient::new("zns://zoo1:2181/services/myservice").await?;

pub async fn new_with_pooling( server_path: &str, pool_config: ConnectionPoolConfig, ) -> Result<BaseRpcClient, ZusError>

Create client with connection pooling enabled

Example

let client = BaseRpcClient::new_with_pooling(
    "zns://zoo1:2181/services/myservice",
    ConnectionPoolConfig::for_gateway()
).await?;

pub fn builder() -> BaseRpcClientBuilder

Create a builder for more advanced configuration

pub async fn for_gateway(server_path: &str) -> Result<BaseRpcClient, ZusError>

Create client optimized for gateway scenarios

Uses connection pooling with sensible defaults for high-throughput:

• min_connections: 2
• max_connections: 10

Example

let client = BaseRpcClient::for_gateway("zns://zoo1:2181/services/backend").await?;

pub fn enable_load_balance(&mut self)

pub fn disable_load_balance(&mut self)

pub fn is_pooling_enabled(&self) -> bool

Check if connection pooling is enabled

Trait Implementations

impl ZusRpcClient for BaseRpcClient

fn sync_call<'life0, 'life1, 'async_trait>( &'life0 self, method: &'life1 str, request: Bytes, timeout_ms: u64, ) -> Pin<Box<dyn Future<Output = Result<Bytes, ZusError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, BaseRpcClient: 'async_trait,

Synchronous RPC call

fn notify_call<'life0, 'life1, 'async_trait>( &'life0 self, method: &'life1 str, request: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), ZusError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, BaseRpcClient: 'async_trait,

Asynchronous RPC call (fire and forget)