Struct Store 

pub struct Store(/* private fields */);

Implementations

impl Store

pub fn local(store: LocalStore) -> Self

pub fn bucket(bucket: S3Store, staging: LocalStore) -> Self

pub async fn reclaim(&self, older_than: Duration) -> Reclaimed

pub async fn writable(&self) -> Result<(), Error>

pub fn scans(&self) -> u64

pub async fn exists(&self, ns: &Namespace, oid: &str) -> bool

pub fn redirect(&self, oid: &str) -> Option<String>

pub fn presigned_upload(&self, ns: &Namespace, oid: &str) -> Option<Presigned>

pub async fn uploaded_size( &self, ns: &Namespace, oid: &str, ) -> Result<Option<u64>, Error>

pub async fn adopt(&self, ns: &Namespace, oid: &str) -> Result<(), Error>

pub async fn open(&self, ns: &Namespace, oid: &str) -> Result<Object, Error>

pub async fn write<S, E>( &self, ns: &Namespace, oid: &str, expected_size: Option<u64>, budget: Option<Budget>, chunks: S, ) -> Result<u64, Error>

where S: Stream<Item = Result<Bytes, E>> + Unpin, E: Error + Send + Sync + 'static,

pub async fn capacity(&self) -> Option<(u64, u64)>

pub async fn usage_of(&self, ns: &Namespace) -> (u64, u64)

pub async fn sweep( &self, ns: &Namespace, retained: &HashSet<String>, grace: Duration, dry_run: bool, ) -> Result<SweepReport, Error>

pub async fn dedupe( &self, ns: &Namespace, dry_run: bool, ) -> Result<DedupeReport, Error>

pub async fn compress( &self, ns: &Namespace, dry_run: bool, ) -> Result<CompressReport, Error>

pub async fn verify(&self, ns: &Namespace) -> Result<VerifyReport, Error>