uqa-storage 0.5.2

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
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

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

//! Committed record histories and snapshot retention shared by storage providers.
//!
//! Record validation is independent of SQL tuple locks and command execution. A physical record replacement must carry the revision it replaces, including the revision of a tombstone. Derived indexes additionally need their owning logical mutation rules; an opaque replacement is not an index merge.

pub(crate) mod commit;
mod deletions;
mod graph;
mod guards;
mod history;
mod hnsw;
mod identifiers;
mod ivf;
mod key;
mod markers;
mod memory;
mod notifications;
mod occurrence;
pub use notifications::{NotificationRecordLayout, NOTIFICATION_PUBLICATION_KEY};
mod outcome;
mod overlay;
mod persistence;
mod populations;
mod projection;
mod receipts;
mod resolution;
mod resources;
mod restore;
mod retention;
mod serializable;
mod session;
mod tombstones;
mod types;
mod vector;
mod vector_fields;
mod view;

pub use session::VectorFieldGuardMaintenance;
pub use vector_fields::{VectorFieldGuard, VectorFieldGuardLayout};

pub use commit::{
    PreparedRecordCommit, PreparedRecordWrite, PreparedWriteCursor, PreparedWriteMetadata,
};
pub use graph::{GraphMutation, GraphRecordKey, GraphRecordLayout};
pub use guards::verify_revision_guards;
pub use history::{RecordHistory, RecordVersion, ScannedRecord, SharedRecordValue};
pub use hnsw::{HNSWRecordHeader, HNSWRecordKey, HNSWRecordLayout, HNSWRecordValue};
pub use identifiers::{
    reserve_identifier_workspace, verify_identifier_allocations, verify_identifier_batches,
    IdentifierAllocation, IdentifierAllocator, IdentifierRequest, ObservedIdentifier,
};
pub use ivf::{IVFRecordHeader, IVFRecordKey, IVFRecordLayout, IVFRecordValue};
pub use memory::{MemoryRecordSnapshot, MemoryVersionStore};
pub use occurrence::{
    OccurrenceRecordKind, OccurrenceRecordLayout, OccurrenceRecordValue, OccurrenceRelatedKey,
};
pub use outcome::{TransactionCompletionError, TransactionOutcome, TransactionOutcomeId};
pub use overlay::{
    PrivateRecordChanges, PrivateRecordCursor, PrivateRecordEntry, PrivateRecordKey,
    PrivateRecordRevision, PrivateRecordSnapshot, PrivateRevisionScope,
};
pub use persistence::{
    resolve_prepared_receipt, CommitErrorOutcome, CommitFailure, CommitFingerprint, CommitReceipt,
    CommitResult, CommitStatus, DatabaseId, RecordPage, StorageMutationOrigin,
    StorageTransactionId, VersionedPersistence,
};
pub use populations::{
    DiskANNPopulationHeader, DiskANNPopulationOrigin, DiskANNPopulationRecordLayout,
};
pub use receipts::{
    receipt_lease_id, ReceiptAcknowledgement, RetainedTransactionAllocation,
    DEFAULT_RECEIPT_RETENTION_LIMIT,
};
pub(crate) use resources::WeakResourceLease;
pub use resources::{
    retain_local_resource, ResourceLease, ResourceLeaseId, ResourceLeaseProvider,
    ResourceLeaseRequest,
};
pub use restore::DatabaseRestore;
pub use retention::{
    verify_version_reclamation, ReclamationHorizon, SnapshotLease, SnapshotLeaseTransport,
    SnapshotRegistry,
};
pub use serializable::{
    admit_serializable, LocalSerializableLeases, LocalSerializableState, SafeSnapshot,
    SerializableCheckpointKey, SerializableCheckpointRecord, SerializableCoordinator,
    SerializableGraph, SerializableKeySpace, SerializableLeases, SerializableOperation,
    SerializableParticipant, SerializablePredicate, SerializablePublication, SerializableStatus,
    SerializableTransactionId, SerializableWriteMark,
};
pub use session::{
    RecordRead, SequencePublicationLease, SerializableReadContext, SerializableSession,
    SerializableSnapshotCapture, SerializableSnapshotOptions, VersionedKeyValueStore,
    VersionedSessionOptions,
};
pub use tombstones::{
    reclaim_key_value_diskann_tombstones, reclaim_tombstone_prefix, verify_tombstone_reclamation,
    verify_tombstone_reclamation_pages, TombstoneReclamationPage, TombstoneReclamationRequest,
    TombstoneReclamationStep, RECLAMATION_DOMAIN_PREFIX, RECLAMATION_EPOCH_NAMESPACE,
    TOMBSTONE_RECLAMATION_PAGE,
};
pub use types::{CommitSequence, RecordWrite, VersionError, VersionResult};
pub use view::{
    retain_record_snapshot, BorrowedRecord, CommittedRecordSnapshot, MergedRecordSnapshot,
    RecordKeyIterator, RecordKeyVisitor, RecordMetadata, RecordPointVisitor, RecordScanVisitor,
    RecordValueVisitor, ScannedVisibleRecord, SelectedRecordRead, VisibleRecord,
    VisibleRecordRevision,
};

mod maintenance;
pub use maintenance::MaintenanceRecordLayout;