somatize-compiler 0.3.0

Graph-to-execution-plan compiler for the Soma runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

//! Graph compiler for Soma pipelines.
//!
//! Transforms a [`Graph`] of filter nodes into an [`ExecutionPlan`]:
//! - Topological ordering and parallelism detection
//! - Cache resolution (content-addressable, cascade invalidation)
//! - Schema validation between connected filters
//! - Distribution wrapping for remote execution
//! - [`Scheduler`] assigns plan nodes to workers

pub mod compiler;
pub mod plan;
pub mod scheduler;

pub use compiler::{
    CompileMode, CompileResult, Compiler, Diagnostic, DiagnosticLevel, FilterRegistry,
    SimpleFilterRegistry, compile, compile_stream,
};
pub use plan::ExecutionPlan;
pub use scheduler::{
    Assignment, DataTransfer, DistributionPlan, Phase, PlanPhase, WorkerInfo, schedule,
};