uni-store 3.3.0

Storage layer for Uni graph database - Lance datasets, LSM deltas, and WAL
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

// SPDX-License-Identifier: Apache-2.0
// Copyright 2024-2026 Dragonscale Team

pub mod adjacency;
pub mod adjacency_manager;
pub mod adjacency_overlay;
pub mod arrow_convert;
pub mod compaction;
pub mod csr;
pub mod delta;
pub mod direction;
#[cfg(feature = "lance-backend")]
pub mod edge;
#[cfg(feature = "lance-backend")]
pub mod index;
pub mod index_manager;
pub mod index_rebuild;
#[cfg(feature = "lance-backend")]
pub mod inverted_index;
#[cfg(feature = "lance-backend")]
pub mod json_index;
pub mod main_edge;
pub mod main_vertex;
pub mod manager;
pub mod muvera_index;
pub mod property_builder;
pub mod resilient_store;
pub mod shadow_csr;
#[cfg(feature = "lance-backend")]
pub mod sparse_index;
pub mod value_codec;
pub mod vertex;
pub mod vid_labels;

use crate::backend::types::FilterExpr;

/// Conjoin the snapshot-isolation version bound onto a scan `filter`.
///
/// When `version` is `Some(hwm)`, restricts the scan to rows at or below the
/// high water mark; `None` leaves the filter unchanged (global visibility).
/// This bound is SSI/OCC-critical and must be applied identically across all
/// snapshot reads — conjoining structured nodes is what guarantees that, where
/// the previous `push_str(" AND …")` would have mis-bound against any body
/// carrying a top-level `OR`.
///
/// Shared by the vertex- and edge-side main-table readers. It lived in
/// `main_vertex` alone while the edge side had no bound at all, which is how
/// the two drifted: L0 and the delta tier gated edge reads by version, the L1
/// main-table fallback did not.
pub(crate) fn with_version_bound(filter: FilterExpr, version: Option<u64>) -> FilterExpr {
    match version {
        Some(hwm) => FilterExpr::all([filter, FilterExpr::version_at_most(hwm)]),
        None => filter,
    }
}

pub use adjacency::AdjacencyDataset;
pub use adjacency_manager::AdjacencyManager;
pub use csr::CompressedSparseRow;
pub use delta::DeltaDataset;
pub use direction::Direction;
#[cfg(feature = "lance-backend")]
pub use edge::EdgeDataset;
#[cfg(feature = "lance-backend")]
pub use index::UidIndex;
pub use index_manager::{IndexManager, IndexRebuildStatus, IndexRebuildTask};
pub use index_rebuild::IndexRebuildManager;
#[cfg(feature = "lance-backend")]
pub use inverted_index::InvertedIndex;
pub use main_edge::{EndpointSide, MainEdgeDataset};
pub use main_vertex::MainVertexDataset;
pub use manager::StorageManager;
pub use resilient_store::ResilientObjectStore;
pub use vertex::VertexDataset;
pub use vid_labels::{EidTypeIndex, VidLabelsIndex};