objstore_fs 0.1.0-alpha.1

Filesystem backend for objstore
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

use std::sync::Arc;

#[derive(Clone, Debug, Default)]
pub struct FsProvider {
    _private: (),
}

impl FsProvider {
    pub const fn new() -> Self {
        Self { _private: () }
    }
}

impl objstore::ObjStoreProvider for FsProvider {
    type Config = crate::FsObjStoreConfig;

    fn kind(&self) -> &'static str {
        crate::FsObjStore::KIND
    }

    fn url_scheme(&self) -> &str {
        "fs"
    }

    fn build(&self, url: &url::Url) -> Result<objstore::DynObjStore, anyhow::Error> {
        if url.scheme() != self.url_scheme() {
            return Err(anyhow::anyhow!(
                "Invalid scheme: expected '{}', got '{}'",
                self.url_scheme(),
                url.scheme()
            ));
        }

        let config = crate::FsObjStoreConfig {
            path: url.path().into(),
        };
        let store = crate::FsObjStore::new(config)?;
        Ok(Arc::new(store) as objstore::DynObjStore)
    }
}