Struct SyncBlobStoreAsAsync 

pub struct SyncBlobStoreAsAsync<S> { /* private fields */ }

Adapter that exposes an existing synchronous BlobStore as an AsyncBlobStore.

This adapter calls the synchronous blob store directly and does not spawn blocking work. Use TokioBlockingBlobStore when a Tokio application needs to adapt a blocking blob backend without stalling async worker threads.

Implementations

impl<S> SyncBlobStoreAsAsync<S>

pub fn new(inner: S) -> Self

Create a new adapter.

pub fn inner(&self) -> &S

Borrow the wrapped blob store.

pub fn into_inner(self) -> S

Consume the adapter and return the wrapped blob store.

Trait Implementations

impl<S: BlobStore> AsyncBlobStore for SyncBlobStoreAsAsync<S>

type Error = <S as BlobStore>::Error

Error type for blob storage operations.

async fn get_blob( &self, reference: &BlobRef, ) -> Result<Option<Vec<u8>>, Self::Error>

Load a blob by reference.

async fn put_blob(&self, bytes: &[u8]) -> Result<BlobRef, Self::Error>

Store bytes and return their content-addressed reference.

async fn delete_blob(&self, reference: &BlobRef) -> Result<(), Self::Error>

Delete a blob. Deleting a missing blob is not an error.

fn read_parallelism(&self) -> usize

Maximum in-flight point reads for default ordered blob reads.

async fn get_blobs_ordered( &self, references: &[BlobRef], ) -> Result<Vec<Option<Vec<u8>>>, Self::Error>

Retrieve multiple blobs while preserving request order.

impl<S: Clone> Clone for SyncBlobStoreAsAsync<S>

fn clone(&self) -> SyncBlobStoreAsAsync<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: Debug> Debug for SyncBlobStoreAsAsync<S>

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

Formats the value using the given formatter.