Struct FilesystemRemoteStore 

pub struct FilesystemRemoteStore { /* private fields */ }

Local-filesystem implementation of RemoteStore.

All operations are idempotent and atomic where applicable. upload uses a .tmp write + rename to prevent torn writes (T-04-10).

Implementations

impl FilesystemRemoteStore

pub fn new(base_dir: PathBuf) -> Result<Self, EdgestoreError>

Create a new FilesystemRemoteStore rooted at base_dir.

Creates base_dir (and all parent directories) if it does not exist.

Trait Implementations

impl RemoteStore for FilesystemRemoteStore

fn upload(&self, hash: &[u8; 32], data: &[u8]) -> Result<(), EdgestoreError>

Store data under hash. Idempotent: if the file already exists, returns Ok(()).

Writes to a .tmp file first, then renames atomically (T-04-10).

fn download(&self, hash: &[u8; 32]) -> Result<Vec<u8>, EdgestoreError>

Download the segment bytes for hash.

Returns EdgestoreError::ReplicationError if the segment is not present.

fn list(&self) -> Result<Vec<[u8; 32]>, EdgestoreError>

List all stored segment hashes by scanning {base_dir}/*.seg.

Filenames that are not exactly 64 lowercase hex characters followed by .seg are silently skipped (T-04-12).

fn delete(&self, hash: &[u8; 32]) -> Result<(), EdgestoreError>

Remove the segment for hash. No-op if the segment does not exist (idempotent).

fn upload_aux( &self, hash: &[u8; 32], ext: &str, data: &[u8], ) -> Result<(), EdgestoreError>

Store a sidecar file for the segment identified by hash.

fn download_aux( &self, hash: &[u8; 32], ext: &str, ) -> Result<Vec<u8>, EdgestoreError>

Retrieve a sidecar file for the segment identified by hash.