Struct GradientStore 

pub struct GradientStore<S: BlockStore> { /* private fields */ }

Gradient store for managing gradients with delta encoding

Implementations

impl<S: BlockStore> GradientStore<S>

pub fn new(store: Arc<S>) -> Self

Create a new gradient store

pub fn with_vcs(store: Arc<S>, vcs: Arc<VersionControl<S>>) -> Self

Create with version control integration

pub fn vcs(&self) -> Option<&Arc<VersionControl<S>>>

Get the version control system, if available

pub async fn store_gradient( &self, data: &[f32], shape: Vec<usize>, provenance: Option<ProvenanceMetadata>, ) -> Result<Cid>

Store a gradient (full)

pub async fn store_gradient_delta( &self, base_cid: &Cid, target: &[f32], shape: Vec<usize>, provenance: Option<ProvenanceMetadata>, ) -> Result<Cid>

Store a gradient as delta from base

pub async fn load_gradient(&self, cid: &Cid) -> Result<GradientData>

Load a gradient and reconstruct if it’s a delta

pub fn reconstruct_gradient<'a>( &'a self, cid: &'a Cid, ) -> Pin<Box<dyn Future<Output = Result<Vec<f32>>> + Send + 'a>>

Reconstruct full gradient from delta chain

pub async fn compute_compression_stats( &self, cid: &Cid, ) -> Result<CompressionStats>

Get compression statistics for a gradient chain