Struct LocalStore 

pub struct LocalStore { /* private fields */ }

Implementations

impl LocalStore

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

impl LocalStore

pub async fn usage(&self) -> (u64, u64)

impl LocalStore

pub fn new(root: impl Into<PathBuf>) -> Self

pub fn validate_oid(oid: &str) -> Result<(), Error>

pub fn scans(&self) -> u64

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

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

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

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

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