allsource-core 0.19.1

High-performance event store core built in Rust
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

// Infrastructure layer - concrete implementations
// This contains:
// - repositories/ (In-memory, PostgreSQL, RocksDB implementations with SierraDB patterns)
// - persistence/ (Storage integrity, checksums, lock-free structures)
// - cluster/ (Node registry, request routing for distributed systems)
// - web/ (HTTP handlers, WebSocket handlers)
// - security/ (Authentication, authorization, rate limiting)
// - config/ (Configuration loading)
// - observability/ (Metrics, tracing)
// - search/ (Vector search engine with HNSW indexing)
// - di/ (Dependency injection container)

pub mod cluster;
pub mod config;
pub mod di;
pub mod observability;
pub mod persistence;
pub mod query;
#[cfg(feature = "replication")]
pub mod replication;
#[cfg(not(feature = "replication"))]
pub mod replication {
    //! Stub types for community builds (replication disabled at compile time).
    /// Stub — replication not available in community edition.
    pub struct WalShipper;
    /// Stub — replication not available in community edition.
    pub struct WalReceiver;
    /// Stub — replication not available in community edition.
    #[derive(Debug, Clone, Copy, serde::Serialize)]
    pub enum ReplicationMode {
        Async,
    }
    /// Stub — replication not available in community edition.
    #[derive(Debug, Clone, serde::Serialize)]
    pub struct ReplicationStatus {
        pub enabled: bool,
    }
    /// Stub — replication not available in community edition.
    #[derive(Debug, Clone, serde::Serialize)]
    pub struct FollowerReplicationStatus {
        pub connected: bool,
    }
}
pub mod repositories;
#[cfg(feature = "server")]
pub mod resp;
pub mod search;
pub mod security;
#[cfg(feature = "server")]
pub mod web;