Rust Adapter Examples : Saikuro

Rust high-throughput provider

Use Rust for performance-sensitive services while callers stay in dynamic languages.

use saikuro::{Provider, Result};

#[tokio::main]
async fn main() -> Result<()> {
    let mut provider = Provider::new("index");
    provider.register("search", |args: Vec<serde_json::Value>| async move {
        Ok(run_search(args))
    });
    provider.serve("tcp://127.0.0.1:7700").await
}

client = Client()
await client.connect()
results = await client.call("index.search", ["saikuro"])

Cross-language streaming fan-out

Rust emits events while TypeScript and Python consume independently.

provider.register_stream("subscribe", |filter: String| async move {
    stream_events(filter)
});

Next Steps