somatize-core 0.3.0

Core types and traits for the Soma computational graph runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

//! Core types and traits for the Soma computational graph runtime.
//!
//! This crate defines the contracts that all other crates depend on:
//! - [`Filter`] — the computation unit (fit/forward)
//! - [`Value`] — typed data flowing between filters (Tensor, JSON, Bytes)
//! - [`Graph`] — DAG of filter nodes and edges
//! - [`CacheKey`] / [`CacheStore`] — content-addressable caching
//! - [`DataStore`] — abstraction for moving data between workers
//! - [`Schema`] — dtype + shape for compile-time validation
//! - [`Event`] — runtime lifecycle events

pub mod cache;
pub mod error;
pub mod event;
pub mod filter;
pub mod graph;
pub mod schema;
pub mod search;
pub mod state;
pub mod store;
pub mod strategy;
pub mod study;
pub mod util;
pub mod value;
pub mod virtual_value;

// Re-export core types for convenience.
pub use cache::{CacheKey, CacheStore, CacheTier, EntryMeta, Origin};
pub use error::{Result, SomaError};
pub use event::{Event, MetricRecord, PlanSummary, RunId, StudyId, TrialId};
pub use filter::{Distribution, Filter, FilterKind, FilterMeta, RemoteTarget, StreamMode};
pub use graph::{Edge, EdgeKind, Graph, Node, NodeId};
pub use schema::{DataType, Dimension, Schema};
pub use search::{Scale, SearchDimension, SearchSpace, Searchable};
pub use state::{MemoryStateStore, StateStore};
#[cfg(feature = "s3")]
pub use store::S3DataStore;
#[cfg(feature = "zarr")]
pub use store::ZarrStore;
pub use store::{
    DataRef, DataStore, LocalDataStore, StorageConfig, StoreMeta, StreamCache, StreamFormat,
    slice_tensor_rows,
};
pub use strategy::{
    ClientSelection, CommunicationProtocol, ExploitStrategy, ExploreStrategy, FederatedAggregation,
    GradientAggregation, Partition, TrainingStrategy,
};
pub use study::{Direction, Objective, PruningStrategy, SearchStrategy, Study, Trial, TrialState};
pub use value::Value;
pub use virtual_value::{ValueStatus, VirtualValue};

// Re-export derive macro
pub use somatize_macros::SomaFilter;