uqa-storage 0.5.0

Document store, inverted index, IVF/HNSW vectors, B-tree, R*Tree, catalog
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

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

//! Immutable marker revisions coordinate structural changes without conflicting independent data writes.

use super::{
    commit::{PreparedWritesBuilder, RecordWriteKind},
    resolution::ResolutionMode,
    CommittedRecordSnapshot, PreparedRecordCommit, RecordVersion, VersionError, VersionResult,
};
use crate::read_control::StorageReadControl;

pub(super) fn resolve(
    original: &PreparedRecordCommit,
    current: &dyn CommittedRecordSnapshot,
    mode: ResolutionMode,
    control: &StorageReadControl,
) -> VersionResult<PreparedRecordCommit> {
    let mut writes = PreparedWritesBuilder::like(original, control)?;
    let mut originals = original.writes();
    while let Some(write) = originals.next(control)? {
        if write.kind() != RecordWriteKind::Marker {
            writes.push(write, control)?;
            continue;
        }
        let value = write.value().ok_or(VersionError::InvalidEncoding(
            "revision markers must have an immutable value",
        ))?;
        let record = current.get(write.key(), control)?;
        if record
            .as_ref()
            .and_then(RecordVersion::value)
            .is_some_and(|stored| &***stored != value)
        {
            return Err(VersionError::InvalidEncoding(
                "revision marker payload changed",
            ));
        }
        writes.push(
            write
                .rebase(record.as_ref().map(RecordVersion::sequence))
                .with_kind(mode.kind(RecordWriteKind::Marker)),
            control,
        )?;
    }
    Ok(writes
        .finish(control)?
        .resolved(original, current.sequence()))
}