moraine 0.5.2

A SlateDB-backed catalog for DuckLake
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

//! The SlateDB layer: key layout and value codecs.
//!
//! Knows nothing about DuckLake semantics.

pub(crate) mod cache;
pub(crate) mod census;
pub(crate) mod compaction;
pub(crate) mod frame;
pub(crate) mod handle;
pub(crate) mod index_encoding;
pub(crate) mod inline;
pub(crate) mod key;
pub(crate) mod open;
pub(crate) mod proto;
pub(crate) mod read;
pub(crate) mod segment;
pub(crate) mod value;

/// Key and value bytes staged onto one write batch.
///
/// A durable commit becomes a single object-store request carrying the
/// whole batch, so this is what decides whether that request is one a link
/// can complete. It counts what moraine hands the store; the object written
/// is larger by the store's own per-entry framing.
#[derive(Debug, Default, Clone, Copy, PartialEq, Eq)]
pub(crate) struct StagedBytes(pub(crate) u64);

impl StagedBytes {
    /// Adds one staged key/value pair. A delete stages its key alone.
    pub(crate) fn add(&mut self, key: usize, value: usize) {
        self.0 = self
            .0
            .saturating_add(key as u64)
            .saturating_add(value as u64);
    }

    pub(crate) fn merge(&mut self, other: StagedBytes) {
        self.0 = self.0.saturating_add(other.0);
    }
}