linkrs-storage 0.1.0

Storage engine with CSR and memory-mapped containers
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

use crate::engine::graph_storage::GraphStorageContext;
use linkrs_core::types::{CompactConfig, CompactResult, CompactStats, CompactTarget};
use linkrs_core::types::{CompactError, Timestamp};

impl CompactTarget for GraphStorageContext {
    fn compact(&self, config: &CompactConfig, ts: Timestamp) -> CompactResult<()> {
        let strategy_desc = match &config.strategy {
            linkrs_core::types::CompactionStrategy::Fixed(ratio) => {
                format!("fixed(ratio={})", ratio)
            }
            linkrs_core::types::CompactionStrategy::Adaptive(cfg) => {
                format!(
                    "adaptive(base={}, reduced={}, threshold={})",
                    cfg.base_ratio, cfg.reduced_ratio, cfg.size_threshold
                )
            }
        };
        log::info!(
            "Starting compaction: enable_structure_compaction={}, strategy={}, ts={}",
            config.enable_structure_compaction,
            strategy_desc,
            ts
        );

        self.compact_maintenance(config, ts)
            .map_err(|err| CompactError::StorageError(err.to_string()))
    }

    fn get_compact_stats(&self) -> CompactStats {
        let total = self.storage_size();
        let used = self.used_storage_size();
        CompactStats::new(total, used)
    }
}