Struct MemoryBlob 

pub struct MemoryBlob { /* private fields */ }

An in-memory cratefield_core::Blob store for module tests. MemoryBlob::new has no presigned URLs (signed_url reports Unsupported, as a directory store does); MemoryBlob::with_presign signs real SigV4 URLs that MemoryBlob::verify_presigned checks back.

Implementations

impl MemoryBlob

pub fn new() -> Self

pub fn with_presign(clock: Arc<dyn Clock>) -> Self

Opts the store into presigning: signed_url and signed_put_url sign real SigV4 URLs stamped from clock, checked back by verify_presigned.

pub fn len(&self) -> usize

How many objects are stored, for assertions.

pub fn is_empty(&self) -> bool

Whether the store is empty, for assertions.

pub fn verify_presigned( &self, url: &str, method: &str, headers: &[(String, String)], ) -> Result<String, SigV4Error>

Verifies a URL this store minted, at its clock’s current time, and returns the key it names.

Errors

As sigv4::verify_presigned, or SigV4Error::Malformed without a clock or a URL path.

Trait Implementations

impl Blob for MemoryBlob

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_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 presigned GET for key, valid for ttl: a URL that serves the object directly, skipping the Worker. Adapters without presigned URLs (a directory store) return BlobError::Unsupported; callers then serve the bytes through get. The URL’s query string is a bearer credential: never log it.

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 Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

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

impl Clone for MemoryBlob

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryBlob

fn default() -> Self

Returns the “default value” for a type.