Trait IncrementalSave 

pub trait IncrementalSave<T>: Send + Sync {
    // Required methods
    fn save_ops(&self, ops: &[Op]) -> Result<()>;
    fn sync(&self) -> Result<()>;
    fn should_snapshot(&self) -> bool;
    fn snapshot(&self, state: &T) -> Result<()>;
}

Trait for incremental (WAL-based) saves from the Store.

Required Methods

fn save_ops(&self, ops: &[Op]) -> Result<()>

Append ops to WAL buffer (no fsync).

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

Flush BufWriter + fsync WAL file.

fn should_snapshot(&self) -> bool

Check if WAL has exceeded the snapshot threshold.

fn snapshot(&self, state: &T) -> Result<()>

Write a full snapshot and reset WAL.

Implementors

impl<T: Replayable + Serialize + DeserializeOwned + Default> IncrementalSave<T> for WalBackend<T>