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 parse_url_opts( object_store_url: &str, ) -> Result<(Arc<dyn ObjectStore>, Path), Error>

Parses an object store URL into the raw (unwrapped, un-prefixed) store and the lake root path, using the same env-var-derived options as connect / connect_with_layer. Exposed so callers that need to apply their own layer (e.g. the object cache client) and also need the root prefix (e.g. to key a write-time cache warm the same way PrefixStore keys a demand read) don’t have to re-parse the URL or duplicate the env-var lowercasing.

pub fn connect_with_layer( object_store_url: &str, layer: impl FnOnce(Arc<dyn ObjectStore>) -> Arc<dyn ObjectStore>, ) -> Result<BlobStorage, Error>

Connects to a blob storage service and applies a layer to the raw store before wrapping it in PrefixStore. The layer receives the full-bucket store so its keys are bucket-relative (including the lake root prefix).

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 probe(&self) -> Result<(), Error>

Probes blob storage reachability and credentials by fetching the first page of a bucket listing (a single request; does not enumerate the bucket).

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.