cobble 0.1.1

A flexible embedded key-value storage engine for distributed systems as well as single-node applications.
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54

pub(crate) const SNAPSHOT_DIR: &str = "snapshot";
pub(crate) const SCHEMA_DIR: &str = "schema";
pub(crate) const GLOBAL_SNAPSHOT_POINTER_NAME: &str = "CURRENT";
pub(crate) const GOVERNANCE_MANIFEST_POINTER_NAME: &str = "MANIFEST";
pub(crate) const GOVERNANCE_MANIFEST_LOCK_NAME: &str = "MANIFEST.lock";
pub(crate) const DATA_DIR: &str = "data";

pub(crate) fn snapshot_manifest_name(id: u64) -> String {
    format!("SNAPSHOT-{}", id)
}

pub(crate) fn snapshot_active_data_name(id: u64) -> String {
    format!("SNAPSHOT-ACTIVE-DATA-{}", id)
}

pub(crate) fn snapshot_active_data_relative_path(id: u64) -> String {
    format!("{}/{}", SNAPSHOT_DIR, snapshot_active_data_name(id))
}

pub fn bucket_snapshot_manifest_path(db_id: &str, snapshot_id: u64) -> String {
    format!("{}/{}", db_id, snapshot_manifest_relative_path(snapshot_id))
}

pub(crate) fn bucket_snapshot_dir(db_id: &str) -> String {
    format!("{}/{}", db_id, SNAPSHOT_DIR)
}

pub(crate) fn snapshot_manifest_relative_path(id: u64) -> String {
    format!("{}/{}", SNAPSHOT_DIR, snapshot_manifest_name(id))
}

pub(crate) fn schema_file_name(id: u64) -> String {
    format!("schema-{}", id)
}

pub(crate) fn schema_file_relative_path(id: u64) -> String {
    format!("{}/{}", SCHEMA_DIR, schema_file_name(id))
}

pub(crate) fn global_snapshot_current_path() -> String {
    format!("{}/{}", SNAPSHOT_DIR, GLOBAL_SNAPSHOT_POINTER_NAME)
}

pub(crate) fn global_snapshot_manifest_path(snapshot_id: u64) -> String {
    format!("{}/{}", SNAPSHOT_DIR, snapshot_manifest_name(snapshot_id))
}

pub(crate) fn global_snapshot_manifest_path_by_pointer(pointer: &str) -> String {
    format!("{}/{}", SNAPSHOT_DIR, pointer)
}

pub(crate) fn governance_manifest_lock_path(root_dir: &str) -> String {
    format!("{}/{}", root_dir, GOVERNANCE_MANIFEST_LOCK_NAME)
}