Computation Graphs
The computation graph system is Cloacina’s reactive execution engine. It wires data sources through accumulators into compiled graph functions that fire automatically when new data arrives.
Define computation graphs with the #[computation_graph] macro, wire accumulators and reactors in your Rust application, and push events directly. Best for:
- Real-time data processing pipelines
- Market data and signal processing
- Applications needing reactive computation
Deploy computation graphs as packaged plugins, receive events via WebSocket or Kafka, and monitor graph health via the HTTP API. Best for:
- Production streaming pipelines
- External event ingestion
- Multi-tenant reactive workloads
| Section | Description |
|---|---|
| Tutorials | Step-by-step learning guides |
| How-to Guides | Task-oriented recipes |
| Reference | API and configuration lookup |
| Explanation | Architecture and design decisions |