Re-exports§
pub use queue::EdgeStorage;
Modules§
Structs§
- Correlated
Payload - Correlated payload with a shared emission identifier.
- Edge
Metrics - Execution
Telemetry - Aggregated timing + diagnostics for a run.
- Executor
- Runtime executor for planner-generated runtime plans.
- Node
Metrics - Owned
Executor - Owned executor that can be reused across runs without leaking the plan.
Enums§
- Edge
Payload - Runtime payload carried over edges. Keep minimal and cheap to clone.
- Execute
Error - Execution errors surfaced by the runtime executor.
- Metrics
Level - Node
Error - Structured node error for better diagnostics.
Traits§
- Node
Handler - Handler abstraction for executing a node.
Functions§
- next_
correlation_ id - Generate a new correlation id.