Struct SyncDiskStorage 

pub struct SyncDiskStorage { /* private fields */ }

High-durability synchronous disk writer.

Every write is flushed to disk before returning. Zero data loss on crash, but lower throughput than AsyncDiskStorage. Enable with WRITE_MODE=sync.

Implementations

impl SyncDiskStorage

pub fn new(path: &str) -> Result<Self, DbError>

Open (or create) the log file at path in append mode.

Trait Implementations

impl StorageBackend for SyncDiskStorage

fn write_entry(&self, entry: &LogEntry) -> Result<(), DbError>

Serialize entry to JSON, write it to the BufWriter, and flush immediately. This call blocks until the OS has accepted the data.

fn read_log(&self) -> Result<Vec<LogEntry>, DbError>

Read all entries from the log file into a Vec.

fn compact(&self, entries: Vec<LogEntry>) -> Result<(), DbError>

Compact the log: write a binary snapshot, swap the log file with an empty one, then reopen the writer.

fn read_at(&self, offset: u64, length: u32) -> Result<Vec<u8>, DbError>

Read exactly length bytes from the log at offset.

fn stream_log_into( &self, f: &mut dyn FnMut(LogEntry, u32) -> ControlFlow<(), ()>, ) -> Result<u64, DbError>

Stream log entries into state using snapshot + delta replay. Same logic as AsyncDiskStorage::stream_log_into — see that method for details.

fn compact_with_hook( &self, entries: Vec<LogEntry>, hook: Option<String>, ) -> Result<(), DbError>

Compact the log and execute an optional post-backup shell hook.

fn get_size(&self) -> Result<u64, DbError>

Return the current size of the persistent log file in bytes.