Struct FileStore 

pub struct FileStore { /* private fields */ }

A content-addressable store backed by a local directory (the file:// backend).

Construct one with FileStore::new (parsing a file:// URL or a bare path) or FileStore::from_root (an already-resolved directory).

Implementations

impl FileStore

pub fn new(store: &str) -> Self

Builds a store from a store URL or path, matching the oracle’s _snapdir_file_store_get_store_dir.

Accepts file:///abs/path, file://localhost/abs/path, file:// followed by an absolute path, or a bare absolute path. A leading file: scheme (with any number of slashes, optionally localhost) is rewritten to a single leading /, and a trailing slash is dropped.

pub fn new_with_config(store: &str, config: TransferConfig) -> Self

Like new, but carries a TransferConfig for concurrency / bandwidth control.

pub fn from_root(root: impl Into<PathBuf>) -> Self

Builds a store rooted at an already-resolved directory.

pub fn from_root_with_config( root: impl Into<PathBuf>, config: TransferConfig, ) -> Self

Like from_root, but carries a TransferConfig for concurrency / bandwidth control. from_root and new delegate here with TransferConfig::default.

pub fn with_meter(self, meter: Option<Arc<Meter>>) -> Self

Attaches (or clears) an optional progress Meter, rides alongside config. The copy paths record bytes-in / bytes-out + per-object progress into it; None (the constructor default) means zero recording and byte-identical behavior. The CLI sets this after construction.

pub fn root(&self) -> &Path

Returns the store’s root directory.

pub fn transfer_config(&self) -> &TransferConfig

The TransferConfig (concurrency / bandwidth) this store was built with. Consumed by the transfer loops in later gates.

Trait Implementations

impl Clone for FileStore

fn clone(&self) -> FileStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FileStore

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

Formats the value using the given formatter.

impl Store for FileStore

fn get_manifest(&self, id: &str) -> Result<Manifest, StoreError>

Reads and parses the manifest stored under id’s sharded path, verifying that its bytes hash back to id before returning it.

fn fetch_files( &self, manifest: &Manifest, dest: &Path, ) -> Result<(), StoreError>

Materializes every entry of manifest under dest, pulling each referenced object from the store and reconstructing the directory tree (files, directories, permissions) rooted at dest.

fn push(&self, manifest: &Manifest, source: &Path) -> Result<(), StoreError>

Uploads the objects referenced by manifest (reading their bytes from the tree rooted at source) and then the manifest itself, filing each under its sharded address.

impl StreamStore for FileStore

fn has_object(&self, checksum: &str) -> Result<bool, StoreError>

Returns true if an object with this content-address already exists in the store.

fn get_object(&self, checksum: &str) -> Result<Vec<u8>, StoreError>

Reads the raw object blob filed under checksum, verifying its bytes hash (BLAKE3) back to checksum before returning them.

fn put_object(&self, checksum: &str, bytes: Vec<u8>) -> Result<(), StoreError>

Writes a raw object blob at its content-address, verifying bytes hash (BLAKE3) to checksum before storing anything.

fn put_manifest(&self, id: &str, manifest: &Manifest) -> Result<(), StoreError>

Writes the manifest object for id, verifying the manifest’s bytes hash back to id before storing it.