Struct Vault 

pub struct Vault { /* private fields */ }

Implementations

impl Vault

pub async fn open(root: impl Into<PathBuf>) -> Result<Vault>

Creates the directory layout (if needed) and removes stale temporary files.

pub fn root(&self) -> &Path

pub fn with_scanner(self, scanner: Option<ScannerConfig>) -> Vault

The same vault, scanning every new file for malware before it is stored (see crate::malware); None = no scan.

pub fn tmp_dir(&self) -> PathBuf

pub fn object_path(&self, sha256: &str) -> AppResult<PathBuf>

Path of the blob with the given hash. The hash must be validated hex.

pub async fn begin_upload(&self, max_bytes: u64) -> AppResult<Upload>

Starts a streaming upload limited to max_bytes.

pub async fn store_bytes(&self, data: &[u8]) -> AppResult<StoredBlob>

Stores a complete in-memory buffer (used by tests and small imports).

pub async fn open_blob(&self, sha256: &str) -> AppResult<File>

pub async fn exists(&self, sha256: &str) -> bool

pub async fn verify(&self, sha256: &str) -> AppResult<bool>

Re-hashes a blob and compares it with its name.

pub async fn check_writable(&self) -> AppResult<()>

Checks that the vault directory is writable (used by /readyz).

pub fn uploads_dir(&self) -> PathBuf

Directory of the chunked uploads in progress. It is on the vault’s file system, so a completed upload moves into objects/ atomically.

pub async fn create_staging(&self, session: Uuid) -> AppResult<()>

Creates the (empty) staging file of a chunked upload.

pub async fn write_staged( &self, session: Uuid, offset: u64, chunk: &[u8], ) -> AppResult<()>

Writes a chunk at offset of a staging file and flushes it to disk. Anything behind offset (the rest of an interrupted earlier chunk that was never confirmed) is cut off first, so the file always equals the confirmed bytes plus this chunk.

pub async fn hash_staged(&self, session: Uuid) -> AppResult<StoredBlob>

SHA-256 and length of a staging file (read once, from disk – the chunks may have arrived across server restarts).

pub async fn adopt_staged(&self, session: Uuid, sha256: &str) -> AppResult<()>

Moves a verified staging file to its content address (or drops it if identical content is stored already).

pub async fn remove_staged(&self, session: Uuid) -> AppResult<()>

Removes the staging file of a session (no error if there is none).

pub async fn stale_staged(&self, older_than: Duration) -> AppResult<Vec<Uuid>>

Staging files not changed for older_than, with their session id.

pub async fn object_prefixes(&self) -> AppResult<Vec<String>>

The two-character directories below objects/ (ab of objects/ab/cd/abcd…), sorted – the pages of Vault::objects_in.

pub async fn objects_in(&self, prefix: &str) -> AppResult<Vec<StoredObject>>

The blobs below objects/<prefix>/, with size and modification time. Anything that is not a blob at its content address (another name, a file in the wrong directory) is skipped – and never removed.

pub async fn object_age(&self, sha256: &str) -> AppResult<Option<Duration>>

How long ago a blob was written or last stored again (see Upload::finish); None if there is no such blob.

pub async fn remove_object_older_than( &self, sha256: &str, grace: Duration, ) -> AppResult<bool>

Removes a blob if it was not written or stored again within grace. Only services::retention calls this, after it made sure that the database refers to the blob nowhere. Returns whether it was removed.

Trait Implementations

impl Clone for Vault

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Vault

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

Formats the value using the given formatter.