linkrs-storage 0.1.0

Storage engine with CSR and memory-mapped containers
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

//! Edge table module: node-group sharded CSR with row-level timestamps.
//!
//! Organization:
//! - `core`: EdgeStore table definition plus per-responsibility operation
//!   modules (`core/store`, `core/owner`, `core/reads`, `core/writes`,
//!   `core/index`, `core/query`, `core/schema_ops`, `core/maintenance`,
//!   `core/recovery`)
//! - `checkpoint`: incremental per-group checkpoint (manifest, group files,
//!   timestamp and property shards)
//! - `compaction`: per-group CSR compaction and property cleanup
//! - `iterator`: sharded scan iterator
//! - `mvcc`: centralized timestamps, tombstones, and GC watermarks
//! - `persistence`: version-5 serialization (flush/load)
//! - `remap`: vertex ID remapping plus offline group-width resharding
//! - `schema_add_column`: staged add-column state machine (prepare/fill/publish/abort)
//! - `schema_drop_column`: staged drop-column state machine (prepare/publish/abort)
//! - `schema_rename_column`: staged rename-column state machine (prepare/publish/abort)
//! - `stats`: tombstone and deletion statistics
//! - `freeze`: explicit per-direction group freeze and unfreeze
//!
//! Write batching contract: point operations (`insert_edge`/`delete_edge`)
//! each wrap a single staged entry in `commit_staging_batch`. Batch entry
//! points (`insert_edges_batch`/`delete_edges_batch`) assemble one
//! multi-entry `EdgeStagingBatch` per call, committed atomically with
//! concentrated rollback of the applied prefix on failure. An empty
//! non-inline table routes `insert_edges_batch` through the grouped
//! direct-write path with identical effects. Each commit is atomic;
//! multi-edge transaction atomicity across calls still relies on the
//! undo-log replay above this layer.

pub mod checkpoint;
pub mod compaction;
pub mod config;
pub mod core;
pub mod freeze;
pub mod iterator;
pub mod mvcc;
pub mod persistence;
pub mod record_form;
pub mod record_form_auto;
pub mod remap;
pub mod schema_add_column;
pub mod schema_drop_column;
pub mod schema_rename_column;
pub mod staging;
pub mod stats;
pub mod wal;

// Re-export commonly used types
pub use config::EdgeTableConfig;
pub use core::{
    DirectionMigrationStats, DirectionNarrowingSuggestion, DirectionUsageSnapshot, EdgeIndexStatus,
    EdgeStorageBreakdown, EdgeStore, EdgeWalRecoveryMode, IncidentDeletedEdge,
    UpdateEdgePropertyByKeyParams,
};
pub use iterator::{AdjacencyBatchAccessor, EdgeTableScanIterator, DEFAULT_ADJACENCY_BATCH};
pub use record_form::MigrateStats;
pub use staging::{EdgeStagingBatch, StagedDelete, StagedInsert};
pub use stats::{
    DeletionStats, FormProfileSnapshot, GroupSegmentStats, ScanPruneReport, TombstoneStats,
};
pub use wal::EdgeWalDiagnosis;

// Re-export from parent
pub use super::{ColdStamps, CsrBase, CsrVariant, HotNbr, Nbr};