lix 0.15.0

Embeddable version control for apps and AI agents.
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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

#[derive(Clone, Copy, Debug, Default, PartialEq, Eq)]
pub struct StorageReadStats {
    pub requested_keys: u64,
    pub unique_storage_keys: u64,
    pub storage_calls: u64,
    pub prefix_lowered: u64,
    pub range_scan_chunks: u64,
    pub prefix_scan_chunks: u64,
    pub scan_key_only_chunks: u64,
    pub scan_full_value_chunks: u64,
    pub scan_rows: u64,
    pub scan_has_more: u64,
    pub scan_limit_rows_total: u64,
    pub scan_limit_rows_max: u64,
}

impl StorageReadStats {
    pub fn add(&mut self, other: Self) {
        self.requested_keys += other.requested_keys;
        self.unique_storage_keys += other.unique_storage_keys;
        self.storage_calls += other.storage_calls;
        self.prefix_lowered += other.prefix_lowered;
        self.range_scan_chunks += other.range_scan_chunks;
        self.prefix_scan_chunks += other.prefix_scan_chunks;
        self.scan_key_only_chunks += other.scan_key_only_chunks;
        self.scan_full_value_chunks += other.scan_full_value_chunks;
        self.scan_rows += other.scan_rows;
        self.scan_has_more += other.scan_has_more;
        self.scan_limit_rows_total += other.scan_limit_rows_total;
        self.scan_limit_rows_max = self.scan_limit_rows_max.max(other.scan_limit_rows_max);
    }
}

#[derive(Clone, Copy, Debug, Default, PartialEq, Eq)]
pub struct StorageReadStatsCollector {
    stats: StorageReadStats,
}

impl StorageReadStatsCollector {
    pub fn new() -> Self {
        Self::default()
    }

    pub fn record(&mut self, stats: StorageReadStats) {
        self.stats.add(stats);
    }

    pub fn snapshot(&self) -> StorageReadStats {
        self.stats
    }

    pub fn reset(&mut self) {
        self.stats = StorageReadStats::default();
    }
}

#[derive(Clone, Debug, PartialEq, Eq)]
pub struct StorageReadResult<T> {
    pub value: T,
    pub stats: StorageReadStats,
}

impl<T> StorageReadResult<T> {
    pub fn new(value: T, stats: StorageReadStats) -> Self {
        Self { value, stats }
    }
}

#[derive(Clone, Copy, Debug, Default, PartialEq, Eq)]
pub struct StorageWriteSetStats {
    pub staged_puts: u64,
    pub staged_deletes: u64,
    pub touched_spaces: u64,
    pub put_batches: u64,
    pub delete_batches: u64,
    pub storage_calls: u64,
    pub written_bytes: u64,
}