motedb 0.2.0

AI-native embedded multimodal database for embodied intelligence (robots, AR glasses, industrial arms).
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124

//! Write Controller — backpressure and rate limiting for high-frequency writes.
//!
//! # Architecture
//! ```text
//! ┌──────────────────────────────────────────────┐
//! │              WriteController                  │
//! │                                               │
//! │  ┌─────────────┐   ┌─────────────────────┐   │
//! │  │ Token Bucket │   │ L0 SSTable Monitor  │   │
//! │  │ (rate limit) │   │ (compaction lag)    │   │
//! │  └──────┬──────┘   └──────────┬──────────┘   │
//! │         │                     │               │
//! │         └──────┬──────────────┘               │
//! │                ↓                              │
//! │  ┌──────────────────────────────────┐        │
//! │  │ BackpressureSignal               │        │
//! │  │  Normal → accept writes          │        │
//! │  │  SlowDown → sleep + retry        │        │
//! │  │  Stop → reject writes            │        │
//! │  └──────────────────────────────────┘        │
//! └──────────────────────────────────────────────┘
//! ```

/// Configuration for the write controller
#[derive(Debug, Clone)]
pub struct WriteControllerConfig {
    /// Maximum writes per second (0 = unlimited)
    pub max_writes_per_sec: u64,

    /// L0 SSTable count → SlowDown signal
    pub l0_slowdown_threshold: usize,

    /// L0 SSTable count → Stop signal
    pub l0_stop_threshold: usize,

    /// SlowDown sleep duration in microseconds
    pub slowdown_sleep_us: u64,

    /// Maximum retry attempts before rejecting
    pub max_retries: usize,
}

impl Default for WriteControllerConfig {
    fn default() -> Self {
        Self {
            max_writes_per_sec: 0,
            l0_slowdown_threshold: 8,
            l0_stop_threshold: 16,
            slowdown_sleep_us: 1000, // 1ms
            max_retries: 10,
        }
    }
}

impl WriteControllerConfig {
    /// Config for robotics (10K writes/sec)
    pub fn for_robotics() -> Self {
        Self {
            max_writes_per_sec: 10_000,
            l0_slowdown_threshold: 6,
            l0_stop_threshold: 12,
            slowdown_sleep_us: 500,
            max_retries: 20,
        }
    }

    /// Unlimited writes (no rate limiting, only L0 monitoring)
    pub fn unlimited() -> Self {
        Self {
            max_writes_per_sec: 0,
            ..Default::default()
        }
    }
}

/// Result of a backpressure check
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum BackpressureSignal {
    /// Normal operation, writes accepted
    Normal,
    /// Approaching limits, writes should slow down
    SlowDown,
    /// At capacity, writes should be rejected
    Stop,
}

impl std::fmt::Display for BackpressureSignal {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        match self {
            Self::Normal => write!(f, "Normal"),
            Self::SlowDown => write!(f, "SlowDown"),
            Self::Stop => write!(f, "Stop"),
        }
    }
}


#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_config_defaults() {
        let config = WriteControllerConfig::default();
        assert_eq!(config.max_writes_per_sec, 0);
        assert_eq!(config.l0_slowdown_threshold, 8);
        assert_eq!(config.l0_stop_threshold, 16);
    }

    #[test]
    fn test_robotics_config() {
        let config = WriteControllerConfig::for_robotics();
        assert_eq!(config.max_writes_per_sec, 10_000);
        assert_eq!(config.l0_slowdown_threshold, 6);
        assert_eq!(config.l0_stop_threshold, 12);
    }

    #[test]
    fn test_signal_display() {
        assert_eq!(format!("{}", BackpressureSignal::Normal), "Normal");
        assert_eq!(format!("{}", BackpressureSignal::SlowDown), "SlowDown");
        assert_eq!(format!("{}", BackpressureSignal::Stop), "Stop");
    }
}