somatize_compiler/lib.rs
1//! Graph compiler for Soma pipelines.
2//!
3//! Transforms a [`Graph`] of filter nodes into an [`ExecutionPlan`]:
4//! - Topological ordering and parallelism detection
5//! - Cache resolution (content-addressable, cascade invalidation)
6//! - Schema validation between connected filters
7//! - Distribution wrapping for remote execution
8//! - [`Scheduler`] assigns plan nodes to workers
9
10pub mod compiler;
11pub mod plan;
12pub mod scheduler;
13
14pub use compiler::{
15 CompileMode, CompileResult, Compiler, Diagnostic, DiagnosticLevel, FilterRegistry,
16 SimpleFilterRegistry, compile,
17};
18pub use plan::ExecutionPlan;
19pub use scheduler::{
20 Assignment, DataTransfer, DistributionPlan, Phase, PlanPhase, WorkerInfo, schedule,
21};