Struct BinaryStore 

pub struct BinaryStore { /* private fields */ }

Implementations

impl BinaryStore

pub const fn path(&self) -> &PathBuf

pub fn new(path: &Path) -> Result<Self>

pub fn new_with_slot( path: &Path, slot: Option<Arc<ArcSwap<File>>>, ) -> Result<Self>

Open (or create) the log. When slot is Some, the freshly opened file handle is published into that existing shared cell instead of a new one — this is how compact keeps the background sync thread pointed at the post-compaction file rather than the renamed-away original (D1).

pub fn write_record(&mut self, kind: RecordKind, payload: &[u8]) -> Result<()>

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

Flush the BufWriter to the kernel buffer (no fsync).

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

fsync the underlying file (kernel buffer → disk).

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

pub fn replay<F>(&self, callback: F) -> Result<()>

where F: FnMut(RecordKind, &[u8]),

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

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

Reopen the file with truncation — discards all existing records. Used by compact to rewrite a fresh log from in-memory state.