Struct IncrementalStorage 

pub struct IncrementalStorage { /* private fields */ }

Incremental storage manager with WAL and checkpointing

Provides efficient incremental persistence with fast recovery.

Implementations

impl IncrementalStorage

pub fn new<P: AsRef<Path>>( base_path: P, config: IncrementalConfig, ) -> Result<Self>

Create or open incremental storage

pub fn log_add(&mut self, doc: &Document) -> Result<()>

Log an add operation to WAL

pub fn log_remove(&mut self, id: &str) -> Result<()>

Log a remove operation to WAL

pub fn log_clear(&mut self) -> Result<()>

Log a clear operation to WAL

pub fn needs_checkpoint(&self) -> bool

Check if checkpoint is needed

pub fn checkpoint<T: Serialize>( &mut self, index: &T, meta: IndexMetadata, ) -> Result<CheckpointMeta>

Create a checkpoint from serializable index data

pub fn load_checkpoint<T: for<'de> Deserialize<'de>>( &self, ) -> Result<Option<(T, CheckpointMeta)>>

Load checkpoint and return deserialized data

pub fn get_wal_entries(&self) -> Result<Vec<WalEntry>>

Get WAL entries since last checkpoint

pub fn manifest(&self) -> &Manifest

Get current manifest state

pub fn stats(&self) -> StorageStats

Get storage statistics

pub fn sync(&mut self) -> Result<()>

Force sync WAL to disk