allsource_core/infrastructure/persistence/
mod.rs

1// Persistence infrastructure layer
2// Contains storage implementations, WAL, snapshots, compaction, and indexing
3
4pub mod arena_pool;
5pub mod backup;
6pub mod batch_processor;
7pub mod compaction;
8pub mod index;
9pub mod lock_free;
10pub mod performance;
11#[cfg(test)]
12mod performance_test;
13pub mod simd_json;
14pub mod snapshot;
15pub mod storage;
16pub mod storage_integrity;
17pub mod wal;
18
19// Re-exports for convenience
20pub use arena_pool::{
21    arena_stats, get_arena, get_arena_with_capacity, ArenaPoolStats, PooledArena, ScopedArena,
22    SizedBufferPool,
23};
24pub use backup::*;
25pub use batch_processor::{
26    ArenaBatchBuffer, BatchProcessor, BatchProcessorConfig, BatchProcessorStats, BatchResult,
27    RawEventData,
28};
29pub use compaction::{CompactionConfig, CompactionManager, CompactionResult, CompactionStrategy};
30pub use index::{EventIndex, IndexEntry};
31pub use lock_free::{
32    LockFreeEventQueue, LockFreeMetrics, MetricsSnapshot, ShardedEventQueue, ShardedQueueStats,
33};
34pub use performance::{BatchWriter, MemoryPool, PerformanceMetrics};
35pub use simd_json::{BatchEventParser, SimdJsonError, SimdJsonParser, SimdJsonStats, ZeroCopyJson};
36pub use snapshot::{
37    CreateSnapshotRequest, CreateSnapshotResponse, ListSnapshotsRequest, ListSnapshotsResponse,
38    Snapshot, SnapshotConfig, SnapshotInfo, SnapshotManager, SnapshotType,
39};
40pub use storage::ParquetStorage;
41pub use storage_integrity::{IntegrityCheckResult, StorageIntegrity};
42pub use wal::{WALConfig, WriteAheadLog};
allsource_core/infrastructure/persistence/mod.rs

allsource_core/infrastructure/persistence/
mod.rs
