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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
use std::path::PathBuf;
pub use kernel::*;
pub use tc_btree as btree;
pub use tc_error as error;
pub use tc_table as table;
#[cfg(feature = "tensor")]
pub use tc_tensor as tensor;
pub use tc_transact as transact;
pub use tc_value as value;
pub use tcgeneric as generic;
mod fs;
mod http;
mod route;
pub mod chain;
pub mod closure;
pub mod cluster;
pub mod collection;
pub mod gateway;
pub mod kernel;
pub mod object;
pub mod scalar;
pub mod state;
pub mod stream;
pub mod txn;
const MIN_CACHE_SIZE: u64 = 5000;
pub async fn mount(
workspace: PathBuf,
data_dir: Option<PathBuf>,
cache_size: u64,
) -> tc_error::TCResult<(fs::Dir, Option<fs::Dir>)> {
if cache_size < MIN_CACHE_SIZE {
return Err(error::TCError::unsupported(format!(
"the minimum cache size is {} bytes",
MIN_CACHE_SIZE
)));
}
let cache = fs::Cache::new(cache_size);
let workspace = fs::load(cache.clone(), workspace).await?;
let data_dir = if let Some(data_dir) = data_dir {
Some(fs::load(cache, data_dir).await?)
} else {
None
};
Ok((workspace, data_dir))
}