allsource_core/infrastructure/
mod.rs

1// Infrastructure layer - concrete implementations
2// This contains:
3// - repositories/ (In-memory, PostgreSQL, RocksDB implementations with SierraDB patterns)
4// - persistence/ (Storage integrity, checksums, lock-free structures)
5// - cluster/ (Node registry, request routing for distributed systems)
6// - web/ (HTTP handlers, WebSocket handlers)
7// - security/ (Authentication, authorization, rate limiting)
8// - config/ (Configuration loading)
9// - observability/ (Metrics, tracing)
10// - search/ (Vector search engine with HNSW indexing)
11// - di/ (Dependency injection container)
12
13pub mod cluster;
14pub mod config;
15pub mod di;
16pub mod observability;
17pub mod persistence;
18pub mod query;
19#[cfg(feature = "replication")]
20pub mod replication;
21#[cfg(not(feature = "replication"))]
22pub mod replication {
23    //! Stub types for community builds (replication disabled at compile time).
24    /// Stub — replication not available in community edition.
25    pub struct WalShipper;
26    /// Stub — replication not available in community edition.
27    pub struct WalReceiver;
28    /// Stub — replication not available in community edition.
29    #[derive(Debug, Clone, Copy, serde::Serialize)]
30    pub enum ReplicationMode {
31        Async,
32    }
33    /// Stub — replication not available in community edition.
34    #[derive(Debug, Clone, serde::Serialize)]
35    pub struct ReplicationStatus {
36        pub enabled: bool,
37    }
38    /// Stub — replication not available in community edition.
39    #[derive(Debug, Clone, serde::Serialize)]
40    pub struct FollowerReplicationStatus {
41        pub connected: bool,
42    }
43}
44pub mod repositories;
45#[cfg(feature = "server")]
46pub mod resp;
47pub mod search;
48pub mod security;
49#[cfg(feature = "server")]
50pub mod web;
allsource_core/infrastructure/mod.rs

allsource_core/infrastructure/
mod.rs
