Struct OpenDalBlobs 

pub struct OpenDalBlobs { /* private fields */ }

Content-addressed blobs on an OpenDAL operator.

Implementations

impl OpenDalBlobs

pub fn new(op: Operator, prefix: impl Into<String>) -> Self

Store blobs under prefix on this operator.

pub fn for_tenant(self, tenant: TenantId) -> Self

Serve one tenant.

Blobs are content-addressed, so without this two tenants writing the same bytes share one object — and erasing it for one destroys it for the other while reporting both requests discharged. The tenant leads the path, so the sharing cannot happen.

Trait Implementations

impl BlobStore for OpenDalBlobs

fn tenant(&self) -> &str

Whose bytes this handle can reach.

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

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

Store bytes and return the address they landed at.

fn put_at<'life0, 'life1, 'async_trait>( &'life0 self, digest: Digest, bytes: &'life1 [u8], ) -> Pin<Box<dyn Future<Output = Result<(), BlobError>> + Send + 'async_trait>>

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

Store bytes at an address that is not their own digest.

fn get_raw<'life0, 'async_trait>( &'life0 self, digest: Digest, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, BlobError>> + Send + 'async_trait>>

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

Fetch exactly what is stored, without verifying it against the address.

fn get<'life0, 'async_trait>( &'life0 self, digest: Digest, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, BlobError>> + Send + 'async_trait>>

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

Fetch bytes, verifying them against the address before returning.

fn expire<'life0, 'life1, 'async_trait>( &'life0 self, digest: Digest, at: Timestamp, reason: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), BlobError>> + Send + 'async_trait>>

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

Drop a blob’s bytes, leaving a tombstone that says it was deliberate.

fn has<'life0, 'async_trait>( &'life0 self, digest: Digest, ) -> Pin<Box<dyn Future<Output = Result<bool, BlobError>> + Send + 'async_trait>>

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

Whether anything is stored at that address.

impl Clone for OpenDalBlobs

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 OpenDalBlobs

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

Formats the value using the given formatter.