Struct GraphSession 

pub struct GraphSession { /* private fields */ }

The primary orchestrator: Graph + filters + cache + events.

let mut lib = FilterLibrary::new();
lib.register("scaler", Box::new(MyScaler::new()));
lib.register("model", Box::new(MyModel::new()));

let mut session = GraphSession::new(graph, lib);
session.fit(&train_x, Some(&train_y))?;
let output = session.forward(&test_x)?;

Implementations

impl GraphSession

pub fn new(graph: Graph, library: FilterLibrary) -> Self

pub fn with_cache(self, cache: Arc<dyn CacheStore>) -> Self

pub fn with_event_bus(self, bus: Arc<EventBus>) -> Self

pub fn with_data_store(self, store: Arc<dyn DataStore>) -> Self

pub fn with_remote_executor(self, executor: Arc<dyn RemoteExecutor>) -> Self

pub fn compile(&self, mode: CompileMode) -> Result<CompileResult>

Compile the graph and return diagnostics without executing.

pub fn run(&mut self, mode: CompileMode) -> Result<HashMap<String, Value>>

Compile and execute the graph, returning all node outputs.

pub fn fit( &mut self, x: &Value, y: Option<&Value>, ) -> Result<HashMap<String, Value>>

Fit all trainable filters in topological order.

For each node in topo order:

1. Resolve input from predecessors
2. If trainable: call fit(input, y), cache state, then forward(input, state)
3. If stateless: call forward(input, Empty)
4. Store output for downstream nodes

pub fn forward(&self, x: &Value) -> Result<Value>

Forward pass through the fitted graph (inference).

Compiles in Inference mode and executes. Trainable filters use states cached during fit().

pub fn forward_batched( &self, data_ref: &DataRef, batch_size: usize, ) -> Result<Value>

Forward pass in batches from a DataStore reference.

pub fn persist_states(&self) -> Result<DataRef>

Persist all trained states to the data store.

pub fn load_states(&mut self, data_ref: &DataRef) -> Result<()>

Load previously persisted states from a data store reference.

pub fn subscribe(&self) -> Receiver<Event>

Subscribe to execution events.

pub fn event_bus(&self) -> &Arc<EventBus>

Access the event bus directly.

pub fn is_fitted(&self) -> bool

Whether the session has been fitted.

pub fn graph(&self) -> &Graph

Access the graph.

pub fn library(&self) -> &FilterLibrary

Access the filter library.

pub fn library_mut(&mut self) -> &mut FilterLibrary

Mutable access to the filter library (for registering filters after creation).