Struct S3Backend 

pub struct S3Backend {
    pub bucket: String,
    pub prefix: String,
    pub region: Option<String>,
    pub endpoint: Option<String>,
    pub sse: SseConfig,
    pub storage_class: S3StorageClass,
    pub transfer_acceleration: bool,
    pub multipart_threshold: usize,
    pub multipart_chunk_size: usize,
    pub timeout: Duration,
    pub retry_config: RetryConfig,
    pub credentials: Option<Credentials>,
}

Enhanced S3 storage backend

Fields

bucket: String

S3 bucket name

prefix: String

Key prefix (path within bucket)

region: Option<String>

AWS region

endpoint: Option<String>

Endpoint URL (for S3-compatible services)

sse: SseConfig

Server-side encryption

storage_class: S3StorageClass

Storage class

transfer_acceleration: bool

Enable transfer acceleration

multipart_threshold: usize

Multipart upload threshold (bytes)

multipart_chunk_size: usize

Multipart chunk size (bytes)

timeout: Duration

Request timeout

retry_config: RetryConfig

Retry configuration

credentials: Option<Credentials>

Credentials

Implementations

impl S3Backend

pub const DEFAULT_MULTIPART_THRESHOLD: usize

Default multipart upload threshold (5 MB)

pub const DEFAULT_MULTIPART_CHUNK_SIZE: usize

Default multipart chunk size (5 MB)

pub fn new(bucket: impl Into<String>, prefix: impl Into<String>) -> Self

Creates a new S3 storage backend

Arguments

• bucket - The S3 bucket name
• prefix - Optional key prefix (path within the bucket)

pub fn with_region(self, region: impl Into<String>) -> Self

Sets the AWS region

pub fn with_endpoint(self, endpoint: impl Into<String>) -> Self

Sets a custom endpoint URL (for S3-compatible services like MinIO)

pub fn with_sse(self, sse: SseConfig) -> Self

Sets server-side encryption

pub fn with_storage_class(self, storage_class: S3StorageClass) -> Self

Sets storage class

pub fn with_transfer_acceleration(self, enabled: bool) -> Self

Enables transfer acceleration

pub fn with_multipart_threshold(self, threshold: usize) -> Self

Sets multipart upload threshold

pub fn with_multipart_chunk_size(self, size: usize) -> Self

Sets multipart chunk size

pub fn with_timeout(self, timeout: Duration) -> Self

Sets request timeout

pub fn with_retry_config(self, config: RetryConfig) -> Self

Sets retry configuration

pub fn with_credentials(self, credentials: Credentials) -> Self

Sets credentials

Trait Implementations

impl Clone for S3Backend

fn clone(&self) -> S3Backend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl CloudStorageBackend for S3Backend

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

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

Gets an object from storage

fn put<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Puts an object to storage

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 an object from storage

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

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

Checks if an object exists

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,

Lists objects with a given prefix

fn is_readonly(&self) -> bool

Returns whether this backend is read-only

impl Debug for S3Backend

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

Formats the value using the given formatter.