Event-sourced · Real-time · Persistent

One world state.
Infinite observers.

Flux ingests events from any producer, derives canonical entity state, and pushes every change to every subscriber in real time. Build agents, dashboards, and automations on a world that never forgets.

Architecture

Three steps. One shared world.

01

Ingest

Any producer publishes events over HTTP. Events are immutable and append-only — the permanent record of everything that happened.

POST /api/events
Authorization: Bearer <token>

{
  "stream": "sensors",
  "source": "my-app",
  "timestamp": 1708694400000,
  "payload": {
    "entity_id": "myns/sensor-01",
    "properties": { "temp": 22.5 }
  }
}
02

Derive

Flux processes events into live entity state. Properties merge on update. The engine owns and maintains the canonical world model.

# Live entity state
{
  "id": "myns/sensor-01",
  "properties": {
    "temp": 22.5,
    "status": "active"
  },
  "lastUpdated": "2026-02-23T..."
}
03

Subscribe

WebSocket subscribers receive every state change in real time — sub-10ms end-to-end. Subscribe to one entity or everything at once.

# WebSocket push
{
  "type": "state_update",
  "entity_id": "sensor-01",
  "property": "temp",
  "value": 22.5,
  "timestamp": "..."
}

Use Cases

Built for whatever moves.

Flux has no built-in semantics. You bring the domain. The engine brings the state.

AI Agents

Multi-agent systems coordinate through shared world state. Agents publish observations and subscribe to peers — no message passing required.

OpenClaw skill available →

IoT & Sensors

Aggregate telemetry from thousands of devices. One WebSocket delivers every state change — no polling, no fan-out logic.

Live Dashboards

WebSocket subscriptions make dashboards trivially real-time. Subscribe once. Receive everything. No polling endpoints to build.

Automation

Trigger workflows from any state change. Subscribe to entities, react to property transitions, chain actions — all event-driven.

SCADA & Industrial

Equipment state, sensor readings, control loop feedback — all in one persistent, replayable world model.

Observability

Publish application events as Flux entities. Query and subscribe to service state without bolting on a separate metrics stack.

<10ms
Event → WebSocket push
End-to-end latency
50k/s
Events per second
On minimal hardware
Replayable history
Immutable event log
4M+
Entities in memory
Lock-free concurrent reads
Live | entities | events/s
Browse the universe →

Pricing

Simple. Permanent. No surprises.

Pay once. Your namespace on the public Flux instance is yours forever.

$4.99 one-time
  • Permanent namespace (e.g. yourname/entity-id)
  • Bearer token for authenticated publishing
  • 10,000 events/min rate limit per namespace
  • Reads always free query and subscribe without auth
  • No renewal pay once, access forever
Get your namespace →

No SLA · No refunds · Abuse = namespace banned · Terms of service

Ready to connect to the world state?

Read the docs, run the quickstart, or grab a namespace and start publishing in minutes.

Read the docs View pricing →