cortex-memory 0.3.1

Self-organizing graph memory for AI agents. Single binary, zero dependencies.
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

use cortex_core::briefing::BriefingEngine;
use cortex_core::{EmbeddingService, GraphEngine, Storage, VectorIndex};
use std::sync::Arc;
use std::time::Duration;
use tracing::{error, info};

/// Background task: pre-warms briefing cache for known agents.
pub struct BriefingPrecomputer<S, E, V, G>
where
    S: Storage + 'static,
    E: EmbeddingService + Clone + Send + Sync + 'static,
    V: VectorIndex + Clone + Send + Sync + 'static,
    G: GraphEngine + Clone + Send + Sync + 'static,
{
    engine: Arc<BriefingEngine<S, E, V, G>>,
    agents: Vec<String>,
    interval: Duration,
}

impl<S, E, V, G> BriefingPrecomputer<S, E, V, G>
where
    S: Storage + 'static,
    E: EmbeddingService + Clone + Send + Sync + 'static,
    V: VectorIndex + Clone + Send + Sync + 'static,
    G: GraphEngine + Clone + Send + Sync + 'static,
{
    pub fn new(
        engine: Arc<BriefingEngine<S, E, V, G>>,
        agents: Vec<String>,
        interval: Duration,
    ) -> Self {
        Self {
            engine,
            agents,
            interval,
        }
    }

    /// Run the pre-computation loop. Call via `tokio::spawn`.
    pub async fn run(self) {
        info!("BriefingPrecomputer started for agents: {:?}", self.agents);
        loop {
            for agent_id in &self.agents {
                match self.engine.generate(agent_id) {
                    Ok(b) => {
                        info!(
                            "Pre-computed briefing for '{}': {} sections, cached={}",
                            agent_id,
                            b.sections.len(),
                            b.cached
                        );
                    }
                    Err(e) => {
                        error!("Failed to pre-compute briefing for '{}': {}", agent_id, e);
                    }
                }
            }
            tokio::time::sleep(self.interval).await;
        }
    }
}