lean_ctx/core/config/
memory.rs1use serde::{Deserialize, Serialize};
4
5use super::Config;
6
7#[derive(Debug, Clone, Default, Serialize, Deserialize, PartialEq)]
11#[serde(rename_all = "lowercase")]
12pub enum MemoryCleanup {
13 #[default]
14 Aggressive,
15 Shared,
16}
17
18impl MemoryCleanup {
19 pub fn from_env() -> Option<Self> {
20 std::env::var("LEAN_CTX_MEMORY_CLEANUP").ok().and_then(|v| {
21 match v.trim().to_lowercase().as_str() {
22 "aggressive" => Some(Self::Aggressive),
23 "shared" => Some(Self::Shared),
24 _ => None,
25 }
26 })
27 }
28
29 pub fn effective(config: &Config) -> Self {
30 if let Some(env_val) = Self::from_env() {
31 return env_val;
32 }
33 config.memory_cleanup.clone()
34 }
35
36 pub fn idle_ttl_secs(&self) -> u64 {
38 match self {
39 Self::Aggressive => 300,
40 Self::Shared => 1800,
41 }
42 }
43
44 pub fn index_retention_multiplier(&self) -> f64 {
46 match self {
47 Self::Aggressive => 1.0,
48 Self::Shared => 3.0,
49 }
50 }
51}
52
53#[derive(Debug, Clone, Default, Serialize, Deserialize, PartialEq)]
58#[serde(rename_all = "lowercase")]
59pub enum MemoryProfile {
60 Low,
61 #[default]
62 Balanced,
63 Performance,
64}
65
66impl MemoryProfile {
67 pub fn from_env() -> Option<Self> {
68 std::env::var("LEAN_CTX_MEMORY_PROFILE").ok().and_then(|v| {
69 match v.trim().to_lowercase().as_str() {
70 "low" => Some(Self::Low),
71 "balanced" => Some(Self::Balanced),
72 "performance" => Some(Self::Performance),
73 _ => None,
74 }
75 })
76 }
77
78 pub fn effective(config: &Config) -> Self {
79 if let Some(env_val) = Self::from_env() {
80 return env_val;
81 }
82 config.memory_profile.clone()
83 }
84
85 pub fn bm25_max_cache_mb(&self) -> u64 {
86 match self {
87 Self::Low => 64,
88 Self::Balanced => 128,
89 Self::Performance => 512,
90 }
91 }
92
93 pub fn semantic_cache_enabled(&self) -> bool {
94 !matches!(self, Self::Low)
95 }
96
97 pub fn embeddings_enabled(&self) -> bool {
98 !matches!(self, Self::Low)
99 }
100}