Struct FilesystemArtifactStorage 

pub struct FilesystemArtifactStorage { /* private fields */ }

Filesystem-backed ArtifactStorage.

Lays each artifact out under <base_path>/<artifact_id>/<filename>. The generated base_url follows the same pattern - configure base_url to match wherever the ArtifactsServer is reachable so clients can resolve the URL.

Implementations

impl FilesystemArtifactStorage

pub fn new(base_path: impl Into<PathBuf>, base_url: impl Into<String>) -> Self

Create a new filesystem-backed store. base_url is the URL prefix (without trailing slash) under which the ArtifactsServer is reachable. The on-disk root at base_path is created lazily on the first store call.

Trait Implementations

impl ArtifactStorage for FilesystemArtifactStorage

fn store<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, artifact_id: &'life1 str, filename: &'life2 str, data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Persist data under artifact_id/filename and return the URL at which it can be retrieved.

fn retrieve<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, artifact_id: &'life1 str, filename: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Retrieve the raw bytes stored at artifact_id/filename.

fn exists<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, artifact_id: &'life1 str, filename: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Whether a blob is stored at artifact_id/filename.

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, artifact_id: &'life1 str, filename: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Delete the blob at artifact_id/filename. Returns Ok(()) if it didn’t exist - idempotent.

fn url(&self, artifact_id: &str, filename: &str) -> String

Stable URL the ArtifactsServer would serve artifact_id/filename at.

fn cleanup_expired<'life0, 'async_trait>( &'life0 self, max_age: Duration, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete every blob whose modified time is older than max_age. Returns the number of blobs removed.

fn cleanup_oldest<'life0, 'async_trait>( &'life0 self, max_count: usize, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Trim the store down so at most max_count blobs remain, deleting the oldest first. Returns the number removed.

fn list<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredArtifactInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Enumerate every stored artifact. Used by retention and tests.

impl Clone for FilesystemArtifactStorage

fn clone(&self) -> FilesystemArtifactStorage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FilesystemArtifactStorage

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

Formats the value using the given formatter.