eventuali_core/performance/
read_replicas.rs

1//! Read replica management for query performance scaling
2//!
3//! Provides read scaling with load balancing capabilities.
4
5/// Read replica configuration
6#[derive(Debug, Clone)]
7pub struct ReplicaConfig {
8    pub read_preference: ReadPreference,
9    pub max_lag_ms: u64,
10}
11
12#[derive(Debug, Clone)]
13pub enum ReadPreference {
14    Primary,
15    Secondary,
16    Nearest,
17}
18
19impl Default for ReplicaConfig {
20    fn default() -> Self {
21        Self {
22            read_preference: ReadPreference::Secondary,
23            max_lag_ms: 1000,
24        }
25    }
26}
27
28/// Read replica manager
29pub struct ReadReplicaManager {
30    #[allow(dead_code)] // Replica configuration settings (stored but not currently accessed in implementation)
31    config: ReplicaConfig,
32}
33
34impl ReadReplicaManager {
35    pub fn new(config: ReplicaConfig) -> Self {
36        Self { config }
37    }
38}