Struct RealFs 

pub struct RealFs { /* private fields */ }

Implementations

impl RealFs

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

pub fn dir(&self) -> &Path

The database directory this filesystem is rooted at.

Trait Implementations

impl Debug for RealFs

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Fs for RealFs

fn append(&mut self, file: FileId, data: &[u8]) -> Result<()>

fn sync(&mut self, file: FileId) -> Result<()>

fn read(&self, file: FileId) -> Result<Vec<u8>>

fn write_atomic(&mut self, file: FileId, data: &[u8]) -> Result<()>

fn snapshot_path(&self) -> Option<PathBuf>

Return the on-disk path of the snapshot file, if any.

fn wal_path(&self) -> Option<PathBuf>

Return the on-disk path of the WAL file, if any.

fn read_prefix(&self, file: FileId, n: usize) -> Result<Vec<u8>>

Read at most n bytes from the beginning of file without loading the full contents.

fn try_lock_exclusive(&self) -> Result<bool>

Try to take the store’s advisory exclusive write lock without blocking.

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

Release the advisory write lock. No-op when it is not held.

fn wal_len(&self) -> Result<u64>

Current length of the WAL in bytes.

fn read_range(&self, file: FileId, from: u64) -> Result<Vec<u8>>

Read file from byte offset from to the end.

fn snapshot_ident(&self) -> Result<Option<(u64, u64)>>

Identity of the current snapshot file as (len, mtime_nanos), or None when no snapshot exists.

fn list_archives(&self) -> Result<Vec<u64>>

List all WAL archive identifiers, sorted ascending (oldest first).

fn read_archive(&self, n: u64) -> Result<Vec<u8>>

Read the byte contents of WAL archive n.

fn archive_wal(&mut self, n: u64) -> Result<()>

Atomically rename the current WAL to wal.<n>.archive (same directory, same filesystem — the rename is guaranteed atomic at the OS level).

fn delete_archive(&mut self, n: u64) -> Result<()>

Delete archive n. No-op if it does not exist.

fn read_horizon_floor(&self) -> Result<u64>

Return the persisted horizon floor — the global frame index of the first commit that is still reachable through surviving archives.

fn write_horizon_floor(&mut self, floor: u64) -> Result<()>

Atomically persist floor so that a subsequent [read_horizon_floor] after reopen returns the same value.

fn has_genesis_marker(&self) -> bool

Return true when the wal.genesis marker file is present.

fn write_genesis_marker(&mut self) -> Result<()>

Durably create the wal.genesis marker file.

fn delete_genesis_marker(&mut self) -> Result<()>

Remove the wal.genesis marker file.