xRPC-rs

High-performance local IPC library for Rust with seamless transport flexibility.

Start with in-process channels for development, scale to shared memory for production IPC, extend to TCP for network deployment—same interface.

Status: Early prototype - working but not production-ready.

Quick Start

use xrpc::{
    RpcClient, RpcServer, MessageChannelAdapter,
    SharedMemoryFrameTransport, SharedMemoryConfig,
};
use serde::{Serialize, Deserialize};
use std::sync::Arc;

#[derive(Serialize, Deserialize)]
struct AddRequest { a: i32, b: i32 }

#[derive(Serialize, Deserialize)]
struct AddResponse { result: i32 }

// =================== Server
let transport = SharedMemoryFrameTransport::create_server("my_service", SharedMemoryConfig::default())?;
let channel = Arc::new(MessageChannelAdapter::new(transport));

let server = RpcServer::new();
server.register_typed("add", |req: AddRequest| async move {
    Ok(AddResponse { result: req.a + req.b })
});
server.serve(channel).await?;

// =================== Client
let transport = SharedMemoryFrameTransport::connect_client("my_service")?;
let channel = MessageChannelAdapter::new(transport);

let client = RpcClient::new(channel);
let _handle = client.start();
let resp: AddResponse = client.call("add", &AddRequest { a: 1, b: 2 }).await?;
assert_eq!(resp.result, 3);

Installation

[dependencies]

xrpc-rs = "0.2"



# Optional codecs: codec-messagepack, codec-cbor, codec-postcard, codec-all

xrpc-rs = { version = "0.2", features = ["codec-messagepack"] }

Status

Architecture

xRPC follows a layered architecture:

Application
    ↓
RpcClient/RpcServer (Layer 3)
    ↓
MessageChannel (Layer 2)
    ↓
FrameTransport (Layer 1)
    ↓
Network/IPC

Transport Comparison

Documentation

• Message Protocol - Binary message format specification

Examples

RPC Client/Server

# Terminal 1

cargo run --example rpc_client_server -- server


# Terminal 2

cargo run --example rpc_client_server -- client

SharedMemory Transport

# Terminal 1

cargo run --example message_transport_shm -- server


# Terminal 2

cargo run --example message_transport_shm -- client

Byte-level Transports

cargo run --example byte_transports

License

MIT License - see LICENSE for details.