SDK & Protocol Compatibility Matrix

use unidb_client::Client;
use unidb_client::models::proto::TelemetryEvent;

// 1. Connect to POSIX shared memory ring
let client = Client::new(
    Some("bench_ring"), 
    Some(32 * 1024 * 1024)
).expect("Failed to connect to shared memory ring");

// 2. Ingest Protobuf event in < 500ns
let event = TelemetryEvent {
    host_id: "prod-worker-01".to_string(),
    event_type: "EXECVE".to_string(),
    pid: 1024,
    ..Default::default()
};

let slot_id = client.insert_telemetry_protobuf(123, &event)?;
println!("Ingested into slot {}", slot_id);

import unidb
import duckdb

# 1. Ingest via Shared Memory IPC (bypasses Python GIL)
client = unidb.Client("bench_ring", 32 * 1024 * 1024)
slot_id = client.insert_telemetry_json(123, {
    "host_id": "prod-worker-01",
    "event_type": "EXECVE",
    "pid": 1024
})

# 2. Query via Arrow Flight SQL in DuckDB
con = duckdb.connect()
con.execute("INSTALL arrow; LOAD arrow;")
df = con.execute("""
    SELECT * FROM flight_sql(
        'grpc://127.0.0.1:8815', 
        'SELECT * FROM code_symbols WHERE kind = \'function\''
    )
""").df()
print(df.head())

import { Client } from '@unidb/client';

// 1. Connect to shared memory ring via NAPI-RS
const client = new Client("bench_ring", 32 * 1024 * 1024);

// 2. Ingest JSON event with zero network hop
const slotId = client.insertTelemetryJson(123, {
    host_id: "prod-worker-01",
    event_type: "EXECVE",
    pid: 1024,
    raw_cmd: "node server.js"
});

console.log("Ingested into slot: " + slotId);

# Connect standard psql CLI directly to UniDB
psql -h 127.0.0.1 -p 5432 -U unidb -d workspace

# Execute relational columnar query
SELECT name, kind, file_path 
FROM code_symbols 
WHERE kind = 'function' 
ORDER BY name 
LIMIT 10;

# Inspect bitemporal horizon
SELECT * FROM code_symbols 
FOR SYSTEM_TIME AS OF '2026-09-20 23:00:00';