Struct AwsS3Storage 

pub struct AwsS3Storage { /* private fields */ }

AWS S3 implementation of CloudStorage.

This implementation provides:

• Automatic multipart uploads for large objects (>5MB)
• Support for all standard S3 storage classes
• Server-side encryption (SSE-S3, SSE-KMS)
• Object metadata and tagging
• Lifecycle policy integration

Example

use llm_shield_cloud_aws::AwsS3Storage;
use llm_shield_cloud::CloudStorage;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let storage = AwsS3Storage::new("my-bucket").await?;

    let data = b"Hello, S3!";
    storage.put_object("test.txt", data).await?;

    let retrieved = storage.get_object("test.txt").await?;
    assert_eq!(data, retrieved.as_slice());

    Ok(())
}

Implementations

impl AwsS3Storage

pub async fn new(bucket: impl Into<String>) -> Result<Self>

Creates a new AWS S3 storage client with default configuration.

Arguments

• bucket - S3 bucket name

Errors

Returns error if AWS configuration cannot be loaded.

pub async fn new_with_region( bucket: impl Into<String>, region: impl Into<String>, ) -> Result<Self>

Creates a new AWS S3 storage client with specific region.

Arguments

• bucket - S3 bucket name
• region - AWS region (e.g., “us-east-1”, “eu-west-1”)

Errors

Returns error if AWS configuration cannot be loaded.

pub fn bucket(&self) -> &str

Gets the bucket name this client is configured for.

pub fn region(&self) -> &str

Gets the AWS region this client is configured for.

Trait Implementations

impl CloudStorage for AwsS3Storage

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

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

Gets an object by key.

fn put_object<'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 with key.

fn delete_object<'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.

fn list_objects<'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 object_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 get_object_metadata<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<ObjectMetadata>> + Send + 'async_trait>>

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

Gets object metadata without fetching the full object.

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

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

Copies an object within the same storage.

fn get_object_with_options<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, key: &'life1 str, options: &'life2 GetObjectOptions, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>>> + Send + 'async_trait>>

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

Gets an object with options.

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

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

Puts an object with options.

fn delete_objects<'life0, 'life1, 'async_trait>( &'life0 self, keys: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Deletes multiple objects in batch.

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

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

Lists objects with metadata.

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

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

Lists objects with a given prefix and limit.

fn move_object<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, from_key: &'life1 str, to_key: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), CloudError>> + Send + 'async_trait>>

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

Moves an object (copy then delete).

fn provider_name(&self) -> &str

Gets the storage provider name (e.g., “s3”, “gcs”, “azure”).