Struct DirBlob 

pub struct DirBlob { /* private fields */ }

Stores blobs as files under base.

Implementations

impl DirBlob

pub fn new(base: impl Into<PathBuf>) -> Self

A store rooted at base. The directory is created on first write.

pub fn arc(base: impl Into<PathBuf>) -> Arc<dyn Blob>

The store as an Arc<dyn Blob>, for Native::blob_arc.

Trait Implementations

impl Blob for DirBlob

fn signed_url<'life0, 'life1, 'async_trait>( &'life0 self, _key: &'life1 str, _ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<String, BlobError>> + Send + 'async_trait>>

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

A directory store has no presigned URLs: neither a GET nor (through the trait default) a PUT.

fn put<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, key: &'life1 str, bytes: &'life2 [u8], content_type: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), BlobError>> + Send + 'async_trait>>

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

Stores bytes at key with content_type, replacing any existing object. Implementations MUST reject a payload larger than MAX_BLOB_BYTES with BlobError::TooLarge via check_blob_size, before writing (issue #136).

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<BlobObject>, BlobError>> + Send + 'async_trait>>

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

Fetches the object at key, or None if there is none.

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

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

Removes the object at key. Idempotent: removing a missing key is Ok.

fn signed_put_url<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, content_type: &'life2 str, content_length: Option<u64>, ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<PresignedPut, BlobError>> + Send + 'async_trait>>

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

A presigned PUT for key with content_type, valid for ttl.