Struct FilterLibrary 

pub struct FilterLibrary { /* private fields */ }

Unified registry of filter implementations, metadata, and trained states.

let mut lib = FilterLibrary::new();
lib.register("scaler", Box::new(MyScaler { scale: 2.0 }));
lib.register("model", Box::new(MyModel::default()));

// Use as compiler registry
let result = somatize_compiler::compile(&graph, &lib, mode, cache)?;

// Use directly with executor — no conversion needed
executor::execute(&plan, &mut ctx, &lib, &cache)?;

Implementations

impl FilterLibrary

pub fn new() -> Self

Create a new library with an in-memory state store.

pub fn with_state_store(states: Arc<dyn StateStore>) -> Self

Create a library with a custom StateStore backend.

pub fn register(&mut self, node_id: impl Into<String>, filter: Box<dyn Filter>)

Register a filter for a given node ID.

pub fn len(&self) -> usize

Number of registered filters.

pub fn is_empty(&self) -> bool

Whether the library is empty.

pub fn get(&self, node_id: &str) -> Option<Arc<dyn Filter>>

Get a filter by node ID.

pub fn set_state(&self, node_id: impl Into<String>, state: Value)

Store a trained state for a node.

Errors bubble up from the underlying StateStore (e.g. I/O on a disk-backed backend). The in-memory default never fails.

pub fn get_state(&self, node_id: &str) -> Option<Arc<Value>>

Retrieve the trained state for a node. The returned Arc<Value> can be dereferenced (&*arc) for the forward hot path without cloning the underlying value.

pub fn clear_states(&self)

Drop all stored states (but keep filters).

pub fn state_store(&self) -> &Arc<dyn StateStore>

Access the underlying StateStore (e.g. to share it across sessions or inspect its contents).

Trait Implementations

impl Default for FilterLibrary

fn default() -> Self

Returns the “default value” for a type.

impl FilterRegistry for FilterLibrary

Implements FilterRegistry so the compiler can read metadata directly from the registered filter implementations.

fn meta(&self, node_id: &str) -> Option<FilterMeta>

fn config_hash(&self, node_id: &str) -> Option<CacheKey>