Never stall an API.
Never lose an event. Stream in real time.

// Node.js Polyglot Client (zero external npm dependencies)
import { WalspoolClient } from "./examples/nodejs/client.js";
const client = new WalspoolClient("http://localhost:9099");

// 1. Subscribe to real-time Server-Sent Events (SSE)
const sub = client.streamLogs({ service: "billing" }, (event) => {
  console.log("⚡ [SSE Event]", event.trace_id, event.payload);
});

// 2. Enqueue event with trace_id (< 15µs local dispatch)
await client.enqueue("billing.charge", { amount: 99.00 }, {
  traceId: "tr-node-101",
  service: "billing"
});

// 3. Query historical trace in < 15µs
const history = await client.queryLogs({ traceId: "tr-node-101" });

# Python Polyglot Client (Standard library urllib)
from examples.python.client import WalspoolClient
client = WalspoolClient("http://localhost:9099")

# 1. Enqueue event with trace_id
resp = client.enqueue("auth.login", {"user_id": "usr_42", "status": "ok"}, trace_id="tr-py-88")

# 2. Query historical logs by trace_id (< 15µs)
traces = client.query_logs(trace_id="tr-py-88", limit=10)

# 3. Stream real-time logs over SSE
for event in client.stream_logs(service="auth"):
    print("⚡ [SSE Event]", event["trace_id"], event["payload"])

# 1. Enqueue an audit event (Instant WAL append + Ring Buffer index)
curl -X POST http://localhost:9099/v1/enqueue \
  -H "Content-Type: application/json" \
  -d '{"topic":"payments","payload":{"trace_id":"tr-curl-01","amount":42.50}}'

# 2. Stream real-time events over Server-Sent Events (SSE)
curl -N http://localhost:9099/v1/logs/stream?service=payments

# 3. Query historical trace index in sub-15µs
curl "http://localhost:9099/v1/logs?trace_id=tr-curl-01&limit=5"

# 4. Scrape Prometheus / OpenMetrics
curl http://localhost:9099/metrics