Struct S3CompatibleStore 

pub struct S3CompatibleStore { /* private fields */ }

Generic S3-compatible blob store implementation

Implementations

impl S3CompatibleStore

pub async fn new(bucket: String) -> BlobResult<Self>

pub async fn with_config(bucket: String, config: S3Config) -> Self

pub fn add_metadata_to_request( request: PutObjectFluentBuilder, metadata: &BlobMetadata, ) -> PutObjectFluentBuilder

Add metadata fields to S3 put request

pub fn extract_blob_metadata(head_result: &HeadObjectOutput) -> BlobMetadata

Extract rich metadata from S3 head_object response

Trait Implementations

impl BlobStore for S3CompatibleStore

fn as_any(&self) -> &dyn Any

Enable downcasting to concrete types

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, content_type: Option<&'life2 str>, stream: ByteStream, ) -> Pin<Box<dyn Future<Output = BlobResult<PutResult>> + Send + 'async_trait>>

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

Store a blob from a stream

fn put_with_metadata<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, key: &'life1 str, content_type: Option<&'life2 str>, filename: Option<&'life3 str>, stream: ByteStream, ) -> Pin<Box<dyn Future<Output = BlobResult<PutResult>> + Send + 'async_trait>>

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

Store a blob from a stream with metadata

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

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

Get a blob as a stream, optionally with range support

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

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

Get blob metadata without content

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

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

Delete a blob

fn list<'life0, 'life1, 'async_trait>( &'life0 self, prefix: Option<&'life1 str>, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = BlobResult<Vec<BlobInfo>>> + Send + 'async_trait>>

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

List blobs with optional prefix filter

fn capabilities(&self) -> StoreCapabilities

Get store capabilities

impl Clone for S3CompatibleStore

fn clone(&self) -> S3CompatibleStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.