Enum Store 

pub enum Store {
    Local(LocalStore),
    Bucket {
        bucket: Box<S3Store>,
        staging: LocalStore,
    },
}

Variants

Local(LocalStore)

Bucket

Fields

bucket: Box<S3Store>

staging: LocalStore

Implementations

impl Store

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

pub fn scans(&self) -> u64

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

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>