Struct BlobStorage 

pub struct BlobStorage { /* private fields */ }

A client for interacting with blob storage.

This struct wraps an ObjectStore and prefixes all paths with a root path, providing a convenient way to interact with a specific “folder” within the blob storage.

Implementations

impl BlobStorage

pub fn new( blob_store: Arc<dyn ObjectStore>, blob_store_root: Path, ) -> BlobStorage

Creates a new BlobStorage instance.

pub fn connect(object_store_url: &str) -> Result<BlobStorage, Error>

Connects to a blob storage service using the provided URL.

pub fn inner(&self) -> Arc<dyn ObjectStore>

Returns a shared reference to the inner ObjectStore.

pub async fn put(&self, obj_path: &str, buffer: Bytes) -> Result<(), Error>

Puts a blob into storage at the specified path.

pub async fn read_blob(&self, obj_path: &str) -> Result<Bytes, Error>

Reads a blob from storage at the specified path.

pub async fn delete(&self, obj_path: &str) -> Result<(), Error>

Deletes a blob from storage at the specified path.

pub async fn delete_batch(&self, objects: &[String]) -> Result<(), Error>

Deletes a batch of blobs from storage.

Trait Implementations

impl Debug for BlobStorage

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

Formats the value using the given formatter.