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
66
67
68
69
70
71
72

pub(crate) mod cache;
pub(crate) mod client;
pub(crate) mod column_stats;
pub(crate) mod compression;
pub(crate) mod cursor;
pub mod edge;
pub(crate) mod encoding;
pub(crate) mod engine;
pub(crate) mod index;
pub(crate) mod macros;
pub mod memory_watermark;
pub mod mvcc_visibility;
pub mod stats;
pub use linkrs_core::types::SnapshotHandle;
pub mod migration_history;
pub(crate) mod schema;
pub mod stats_reader;
pub(crate) mod thread_pool;

mod batch_ops;
mod metrics;
pub(crate) mod persistence;
pub(crate) mod safe_read;
pub(crate) mod types;
pub(crate) mod vertex;

#[cfg(any(test, feature = "test-support"))]
mod test_mock;

pub use batch_ops::AutoCommitBatchOps;
pub use batch_ops::AutoCommitGroupOps;
pub use client::{
    CatalogStore, GraphStore, PurgeTarget, QueryStorage, StorageAdmin, StorageAuthOps,
    StorageClient, StorageCommitOps, StorageGcOps, StorageMaintenance, StorageOperationContext,
    StorageOperationContextOps, StoragePersistenceOps, StorageReader, StorageRecoveryOps,
    StorageSchemaContextOps, StorageSchemaOps, StorageSnapshotOps, StorageStats,
    StorageSyncContextOps, StorageTtlPurgeOps, StorageWriter, TtlPurgeEntry,
};
pub use cursor::{
    open_edge_scan, open_index_cursor, open_vertex_scan, ColumnValues, EdgeColumnBatch, EdgeCursor,
    FlatVertexRecord, IndexCursor, IndexPredicate, IndexRow, IndexScanPlan, PartitionSelector,
    PredicateRange, PropertyColumn, RequiredProperty, ScanOptions, ScanPredicate, ScanTarget,
    ShardSlice, VecEdgeCursor, VecVertexCursor, VertexColumnBatch, VertexCursor,
};
pub use engine::config::{PropertyGraphConfig, ResourceConfig};
pub use engine::graph_storage::{AutoCommitBatchWindow, GraphStorage, WriteGateStats};
pub use engine::persistence_coordinator::{
    CatalogLockDiagnostic, CheckpointDiagnostics, CheckpointStats, GcEventSink, PersistenceConfig,
    PersistenceDiagnostics, PersistenceFaultPoint, SnapshotStats, StorageEvent,
    StorageEventCallback,
};
pub use engine::resource_budget::{
    MemoryAccounting, MemoryBudget, MemoryCategory, MemoryReservation, MemoryUsage,
    ResourceSnapshot,
};
pub use engine::sync_wrapper::SyncWrapper;
pub use engine::transaction::{StagedWriteMark, UndoTarget};
pub use engine::WalMetrics;
pub use index::{
    GenerationBuildState, GenerationState, IndexManifest, IndexShard, ManifestCatalog,
    ManifestCatalogStats, ManifestHandle,
};
pub use metrics::MetricsStorage;
pub use migration_history::{MigrationHistoryManager, MigrationHistoryRecord, MigrationStatus};
pub use schema::{ChangeDetails, ChangeLog, LabelVersionHistory, PropertyChange, SchemaObjectType};
pub use stats_reader::{ColumnStatsReader, ColumnStatsSnapshot};
pub use types::StoragePropertyDef;

pub use linkrs_core::StorageError;

#[cfg(any(test, feature = "test-support"))]
pub use test_mock::MockStorage;