Struct S3Store 

pub struct S3Store<L: Store> { /* private fields */ }

S3-backed store with local caching and background sync.

Writes go to the local store first (fast), then are synced to S3 in the background. Reads check local store first, then fall back to S3.

Implementations

impl<L: Store + 'static> S3Store<L>

pub async fn new(local: Arc<L>, config: S3Config) -> Result<Self, S3StoreError>

Create a new S3 store wrapping a local store.

Spawns a background task for non-blocking S3 uploads.

pub fn shutdown(&self)

Shutdown the background sync task

Trait Implementations

impl<L: Store> Drop for S3Store<L>

fn drop(&mut self)

Executes the destructor for this type.

impl<L: Store + 'static> Store for S3Store<L>

fn put<'life0, 'async_trait>( &'life0 self, hash: Hash, data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<bool, StoreError>> + Send + 'async_trait>>

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

Store data by its hash Returns true if newly stored, false if already existed

fn get<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 Hash, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<u8>>, StoreError>> + Send + 'async_trait>>

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

Retrieve data by hash Returns data or None if not found

fn has<'life0, 'life1, 'async_trait>( &'life0 self, hash: &'life1 Hash, ) -> Pin<Box<dyn Future<Output = Result<bool, StoreError>> + Send + 'async_trait>>

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

Check if hash exists

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

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

Delete by hash Returns true if deleted, false if didn’t exist