Struct Service 

pub struct Service { /* private fields */ }

The high-level interface to the storage vault.

Service is the entry point for all filesystem operations in this application. It owns the path to the vault directory and exposes a small, focused API for saving, retrieving, and deleting blobs.

Internally, writes go through an internal transaction which guarantees atomicity: a failed write can never leave a corrupted or partial file in the vault.

Implementations

impl Service

pub fn new<P>(vault_path: P) -> Self

where P: Into<PathBuf>,

Creates a new Service rooted at the given vault directory.

The path is not validated here — if the directory does not exist when a transaction is attempted, a crate::storage::Error::VaultNotFound will be returned at that point.

pub async fn try_save<S, E>( &self, file_name: &str, payload: Payload<S, E>, ) -> Result<Metadata>

where S: Stream<Item = Result<Bytes, E>> + Unpin, E: Into<Box<dyn StdErr + Send + Sync>>,

Streams a payload to disk and commits it atomically to the vault.

This is the main entry point for all uploads. Internally it creates an internal transaction, streams all bytes to a temporary staging file, then performs an atomic rename(2) to the final CAS path (the BLAKE3 hash of the content). Returns the file Metadata on success.

If anything fails mid-stream, the temporary file is cleaned up before the error is returned.

Errors

• Returns crate::storage::Error::InvalidFileName if file_name contains /, \, or is empty.
• Returns crate::storage::Error::FileAlreadyExists if a file with that name already exists in the vault.
• Returns crate::storage::Error if a disk I/O failure occurs during streaming or the atomic rename.

impl Service

pub async fn delete_blob(&self, hash_str: &str) -> Result<()>

Deletes the blob at the given hash string from the vault.

This is intentionally idempotent: if the file does not exist, Ok(()) is returned without error. This makes it safe to call even when the physical file has already been removed or was never committed.

Errors

• Returns crate::storage::Error::Internal if the filesystem returns any error other than NotFound (e.g., permission denied).

pub async fn get_blob(&self, hash_str: &str) -> Result<File>

Opens and returns the blob file at the given hash string for reading.

The returned [tokio::fs::File] handle can be wrapped in a ReaderStream for direct streaming to an HTTP response body without loading the file into memory.

Errors

• Returns crate::storage::Error::NotFound if no blob with that hash exists in the vault.

Trait Implementations

impl Clone for Service

fn clone(&self) -> Service

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Service

fn default() -> Service

Returns the “default value” for a type.