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 cold_tier;
8pub mod compaction;
9pub mod index;
10pub mod lock_free;
11pub mod performance;
12pub mod simd_filter;
13pub mod simd_json;
14pub mod snapshot;
15pub mod storage;
16pub mod storage_integrity;
17pub mod system_bootstrap;
18pub mod system_store;
19pub mod tenant_loader;
20pub mod wal;
21
22// Re-exports for convenience
23pub use arena_pool::{
24    ArenaPoolStats, PooledArena, ScopedArena, SizedBufferPool, arena_stats, get_arena,
25    get_arena_with_capacity,
26};
27pub use backup::*;
28pub use batch_processor::{
29    ArenaBatchBuffer, BatchProcessor, BatchProcessorConfig, BatchProcessorStats, BatchResult,
30    RawEventData,
31};
32pub use cold_tier::{ArchiveTarget, LocalFsArchive};
33pub use compaction::{CompactionConfig, CompactionManager, CompactionResult, CompactionStrategy};
34pub use index::{EventIndex, IndexEntry};
35pub use lock_free::{
36    LockFreeEventQueue, LockFreeMetrics, MetricsSnapshot, ShardedEventQueue, ShardedQueueStats,
37};
38pub use performance::{BatchWriter, MemoryPool, PerformanceMetrics};
39pub use simd_filter::{
40    FilterPredicate, SimdEventFilter, SimdFilterStats, filter_events_simd,
41    filter_events_simd_indices,
42};
43pub use simd_json::{BatchEventParser, SimdJsonError, SimdJsonParser, SimdJsonStats, ZeroCopyJson};
44pub use snapshot::{
45    CreateSnapshotRequest, CreateSnapshotResponse, ListSnapshotsRequest, ListSnapshotsResponse,
46    Snapshot, SnapshotConfig, SnapshotInfo, SnapshotManager, SnapshotType,
47};
48pub use storage::{
49    BatchWriteResult, BatchWriteStats, DEFAULT_BATCH_SIZE, DEFAULT_FLUSH_TIMEOUT_MS,
50    MigrationReport, ParquetStorage, ParquetStorageConfig,
51};
52pub use storage_integrity::{IntegrityCheckResult, StorageIntegrity};
53pub use system_bootstrap::{SystemBootstrap, SystemRepositories};
54pub use system_store::SystemMetadataStore;
55pub use tenant_loader::{DEFAULT_LOAD_TIMEOUT, TenantLoader};
56pub use wal::{WALConfig, WriteAheadLog};
allsource_core/infrastructure/persistence/mod.rs

allsource_core/infrastructure/persistence/
mod.rs
