Struct Storage

pub struct Storage<B: StorageBackend> { /* private fields */ }

High-level storage interface with additional features

Implementations

impl<B: StorageBackend> Storage<B>

pub fn new(backend: B) -> Self

Create a new storage instance

pub fn with_config(backend: B, config: StorageConfig) -> Self

Create a storage instance with custom configuration

pub async fn put( &self, path: &str, data: &[u8], options: Option<UploadOptions>, ) -> StorageResult<FileMetadata>

Store a file with validation

pub async fn put_stream<S>( &self, path: &str, stream: S, options: Option<UploadOptions>, ) -> StorageResult<FileMetadata>

where S: Stream<Item = Result<Bytes, Error>> + Send + Unpin,

Store a file from a stream with validation

pub async fn get(&self, path: &str) -> StorageResult<Option<Bytes>>

Retrieve a file

pub async fn get_stream( &self, path: &str, ) -> StorageResult<Option<Box<dyn Stream<Item = Result<Bytes, Error>> + Send + Unpin>>>

Get a file as a stream

pub async fn exists(&self, path: &str) -> StorageResult<bool>

Check if file exists

pub async fn metadata(&self, path: &str) -> StorageResult<Option<FileMetadata>>

Get file metadata

pub async fn delete(&self, path: &str) -> StorageResult<bool>

Delete a file

pub async fn list( &self, prefix: Option<&str>, limit: Option<u32>, ) -> StorageResult<Vec<FileMetadata>>

List files

pub async fn copy( &self, from: &str, to: &str, options: Option<UploadOptions>, ) -> StorageResult<FileMetadata>

Copy a file

pub async fn move_file( &self, from: &str, to: &str, options: Option<UploadOptions>, ) -> StorageResult<FileMetadata>

Move a file

pub async fn signed_url( &self, path: &str, expires_in: Duration, ) -> StorageResult<String>

Generate signed URL

pub async fn public_url(&self, path: &str) -> StorageResult<String>

Generate public URL

pub async fn stats(&self) -> StorageResult<StorageStats>

Get storage statistics

pub async fn delete_many(&self, paths: &[&str]) -> StorageResult<Vec<String>>

Delete multiple files