Expand description
Ring 0 DAG executor for event processing.
DagExecutor processes events through a finalized StreamingDag in
topological order. It uses the pre-computed RoutingTable (F-DAG-002)
for O(1) dispatch and integrates with the Operator trait for operator
invocation.
§Architecture
┌──────────────────────────────────────────────────────────────────┐
│ RING 0: HOT PATH │
│ │
│ process_event(source, event) │
│ │ │
│ ▼ │
│ ┌──────────┐ topological ┌───────────┐ route_output() │
│ │ enqueue │──────order────▶│ operator │──────────────────┐ │
│ │ (input │ │ .process()│ │ │
│ │ queue) │ └───────────┘ │ │
│ └──────────┘ │ │
│ ▲ │ │
│ │ ┌─────────────────┐ │ │
│ └──────────────────│ RoutingTable │◀────────────────┘ │
│ enqueue targets │ O(1) lookup │ │
│ └─────────────────┘ │
└──────────────────────────────────────────────────────────────────┘§Latency Budget
| Component | Budget |
|---|---|
| Routing table lookup | < 50ns |
| Operator dispatch | < 200ns |
| Multicast to N consumers | < 100ns |
| State access | < 200ns |
| Total | < 500ns |
Structs§
- DagExecutor
- Ring 0 DAG executor for event processing.
- DagExecutor
Metrics - Metrics tracked by the DAG executor.