Crate daedalus_runtime 

Runtime orchestration scaffolding. See PLAN.md for the detailed roadmap. Transforms planner ExecutionPlan into a runnable RuntimePlan with edge policies and schedulable segments.

Re-exports

pub use executor::EdgePayload;

pub use executor::ExecuteError;

pub use executor::ExecutionTelemetry;

pub use executor::Executor;

pub use executor::MetricsLevel;

pub use executor::NodeError;

pub use executor::NodeHandler;

pub use executor::NodeMetrics;

pub use fanin::FanIn;

pub use handles::NodeHandle;

pub use handles::PortHandle;

pub use host_bridge::HOST_BRIDGE_META_KEY;

pub use host_bridge::HostBridgeHandle;

pub use host_bridge::HostBridgeManager;

pub use host_bridge::HostBridgeSerialized;

pub use host_bridge::HostBridgeSerializedPayload;

pub use host_bridge::bridge_handler;

pub use io::NodeIo;

pub use io::register_output_mover;

pub use config::*;

Modules

capabilities

config

debug

Debug helpers for serializing/deserializing runtime plans.

executor

fanin

graph_builder

handler_registry

handles

host_bridge

io

snapshot

Snapshot/restore scaffolding (feature-gated via snapshots when wiring real storage).

state

Structs

ConversionRegistry

RuntimeNode

Runtime node with policy hints.

RuntimePlan

Final runtime plan, derived from planner output.

RuntimeSegment

A schedulable segment (may group GPU-required nodes).

SchedulerConfig

Scheduler configuration for edge policies and backpressure.

Enums

BackpressureStrategy

Backpressure strategy applied to queues.

EdgePolicyKind

Edge policy kinds; default is FIFO.

Functions

apply_node_prefix

Apply a plugin prefix to a node id without duplicating overlapping segments.

build_runtime

Build a runtime plan from an execution plan; later will wire policies and orchestrator.

convert_arc

Attempt to convert an Arc<dyn Any> into T using the default registry.