Struct DeltaManager 

pub struct DeltaManager { /* private fields */ }

Delta computation manager

Implementations

impl DeltaManager

pub fn new(config: DeltaConfig) -> Self

Create new delta manager

pub fn record_change(&self, change: ChangeRecord) -> Result<()>

Record a change in the system

pub fn record_entity_added( &self, entity_id: String, batch_id: Option<Uuid>, ) -> Result<()>

Record entity addition

pub fn record_entity_removed(&self, entity_id: String) -> Result<()>

Record entity removal

pub fn record_triple_added( &self, triple: Triple, batch_id: Option<Uuid>, ) -> Result<()>

Record triple addition

pub fn record_triple_removed(&self, triple: Triple) -> Result<()>

Record triple removal

pub fn record_bulk_import( &self, entity_count: usize, triple_count: usize, ) -> Result<Uuid>

Record bulk import operation

pub async fn compute_delta( &self, model: &dyn EmbeddingModel, ) -> Result<DeltaResult>

Compute delta from baseline to current state

pub async fn apply_incremental_update( &self, model: &mut dyn EmbeddingModel, delta_result: &DeltaResult, ) -> Result<()>

Apply incremental updates to the model

pub async fn set_baseline_from_model( &self, model: &dyn EmbeddingModel, ) -> Result<()>

Set baseline embeddings from current model state

pub fn get_changes_in_window( &self, window_start: DateTime<Utc>, ) -> Vec<ChangeRecord>

Get change log within time window

pub fn get_change_statistics(&self) -> ChangeStatistics

Get statistics about changes

pub fn clear_change_log(&self)

Clear change log

pub fn set_incremental_strategy(&mut self, strategy: IncrementalStrategy)

Set incremental update strategy

pub fn should_compute_delta(&self) -> bool

Check if delta computation is needed

pub fn get_last_delta_timestamp(&self) -> Option<DateTime<Utc>>

Get last delta timestamp