ClawQLStreams
Event-driven autonomous agents you own — not a metered lab runtime.
World events enter. WORM records everything. Significance filters decide when agents wake — with full MCP tools, virtual-key budgets, and Durable Object scale.
One event loop. Three ways to respond.
The same subscription can audit continuously, keep agents ambiently aware, and escalate only when the world crosses a threshold — without a human opening a chat.
Reactive
Every event writes to WORM immediately — compliance-grade recording whether an agent wakes or not.
Ambient
Events buffer in NATS and surface on the next MCP tool call — awareness without spawning a subprocess.
Autonomous
A significance filter escalates only what matters into a full agent session with ClawQL tools and budget.
Anything in. Anything out. Events on the bus.
ClawQL Core turns any API — or a page's own WebMCP tools — into MCP. mcp-api-adapter turns MCP back into OpenAPI, GraphQL, gRPC, CLI, WebSocket, QR, or /mcp-ui. Streams wraps that fabric with NATS JetStream so the bus can act without a human at the console — Event Stream in, WORM and RTP out.
ESB lesson, agent era: N×M protocol integrations collapse to N+M. Streams is how the fabric reacts to webhooks, NATS topics, cron, and live sockets — not only interactive MCP clients.
Infinite session scale without losing the audit trail
Write-once Durable Object code runs on Cloudflare or celld— Deno's self-hosted DO runtime with LTX replication to your bucket (~$0.05 per resident cell-month). Regulated tenants keep Kubernetes HPA until celld is production-stable.
Virtual-key budgets
Keys bind on session create and expire on destroy — every autonomous wake has a hard spend ceiling through
clawql-inference.WORM on every action
Reactive ingest never waits on the model. Forensic reconstruction is a hash chain you own, not a vendor console export.
Training emission
Optional RTP + OpenBenchTrace export with consent scopes — the Intelligence Flywheel without surrendering sovereignty.
The pattern labs built for themselves — as a platform
Stripe Minions, Anthropic Managed Agents, and OpenAI Agents SDK all implement event → context → reason → tools → audit. ClawQL Streams is that pattern with operator-owned infrastructure.
| Capability | Stripe Minions | Managed Agents | Agents SDK | ClawQL Streams |
|---|---|---|---|---|
| Sovereignty | Internal only | Anthropic-hosted | Managed runtime | Self-host or Cloudflare |
| Triggers | Slack reactions | Cron / API | Pipeline / API | WebSocket · NATS · webhook · cron |
| Tools | Custom Toolshed | Built-in + custom | Built-in + custom | Any MCP surface via Protocol Fabric |
| Audit | Internal | Provider logs | Provider logs | Operator-owned WORM Merkle trail |
| Scale | Custom | Session hours | Managed | celld · Cloudflare DO · K8s HPA |
Draft specs live on docs.clawql.com
Streams is shipping as an opt-in coordination layer over packages you already deploy — inference, payments, Ouroboros, NATS, and WORM memory.
- ClawQL Streams specification — event loop, delivery modes, significance filters, training emission
- ClawQL Durable Objects — SubscriptionDO, AgentSessionDO, sidecars, K8s parity
- ClawQL celld integration — self-hosted DO runtime, LTX WORM trail, fleet deploy
- mcp-api-adapter — five (plus WebSocket) surfaces that complete the Protocol Fabric
Put an event loop under your agents
Start a trial on the Agentic Gateway today. When Streams lands, the same MCP endpoint, vault, and WORM trail become the autonomous runtime — not a second product.