Struct ProviderObjectStore 

pub struct ProviderObjectStore { /* private fields */ }

Adapts the upstream object_store provider surface to the narrower LoonFS contract.

Implementations

impl ProviderObjectStore

pub fn new( inner: Arc<dyn ObjectStore>, multipart: Option<Arc<dyn MultipartStore>>, config: ProviderObjectStoreConfig, ) -> Result<Self>

Wraps a provider client and optional native multipart surface.

Construction fails when config.key_prefix is not a normalized, non-escaping logical prefix.

Trait Implementations

impl Clone for ProviderObjectStore

fn clone(&self) -> ProviderObjectStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProviderObjectStore

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

Formats the value using the given formatter.

impl ObjectStore for ProviderObjectStore

fn get<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, range: Option<ByteRange>, ) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>>> + Send + 'async_trait>>

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

Bounded reads issue the ranged GET directly — one round trip, not a sizing HEAD plus a GET — and pay a single HEAD only on the failure path, to decide whether the range or the transport was the problem. The contract matches the local reference provider exactly: a missing object is Ok(None) however the request was shaped, an end past the object clamps, start == size reads empty, and start > size is InvalidRange.

fn put_streamed<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, body: ByteStream, mode: PutMode, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Cuts the payload into parts as it arrives and uploads them one at a time, so a large object costs one part of memory instead of its own size.

The first part is cut before anything is decided. A payload that ends inside it is an ordinary ObjectStore::put with the caller’s mode intact — which is the same size line put itself draws, so a small streamed write behaves exactly like a small buffered one. Anything longer goes through the provider’s multipart upload, whose completion is an unconditional overwrite.

fn head<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ObjectMetadata>>> + Send + 'async_trait>>

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

Reads metadata for one key, returning None when the object is absent.

fn get_with_metadata<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ObjectBody>>> + Send + 'async_trait>>

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

Reads complete bytes and identity metadata from one self-consistent observation.

fn put<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, bytes: Bytes, mode: PutMode, ) -> Pin<Box<dyn Future<Output = Result<ObjectMetadata>> + Send + 'async_trait>>

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

Writes bytes under the requested overwrite or provider-enforced precondition.

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Deletes a key idempotently and makes its absence immediately authoritative.

fn list_prefix_stream(&self, prefix: &str) -> BoxStream<'static, Result<String>>

Streams keys under prefix in ascending lexicographic order.

fn head_stored_checksum<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<StoredObjectChecksum>>> + Send + 'async_trait>>

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

Reads size and the stored full-object checksum for one key, returning None when the object is absent.

fn create_multipart_upload<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

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

Opens a provider multipart upload targeting key, whose eventual checksum covers the whole assembled object.

fn complete_multipart_upload<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, key: &'life1 str, provider_upload_id: &'life2 str, parts: &'life3 [MultipartPart], full_object_checksum: &'life4 StorageChecksum, ) -> Pin<Box<dyn Future<Output = Result<MultipartCompletion>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Asks the provider to assemble parts into the object at key.

fn abort_multipart_upload<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, provider_upload_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Abandons a provider multipart upload and the parts it accumulated.

fn list_prefix<'life0, 'life1, 'async_trait>( &'life0 self, prefix: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

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

Collects and sorts every key under prefix.

fn put_overwrite<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<ObjectMetadata>> + Send + 'async_trait>>

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

Writes bytes unconditionally, replacing any existing object at key.

fn put_if_absent<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<ObjectMetadata>> + Send + 'async_trait>>

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

Creates key only when no object is present.

fn put_immutable_verified<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), ImmutableWriteError>> + Send + 'async_trait>>

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

Writes bytes under an immutable key and accepts success only when the key contains exactly those bytes.

fn compare_and_swap<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, expected_etag: &'life2 str, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<ObjectMetadata>> + Send + 'async_trait>>

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

Replaces key only while its current opaque token equals expected_etag.