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

use cortex_core::*;
use std::sync::atomic::AtomicU64;
use std::sync::Arc;
use std::sync::RwLock as StdRwLock;

/// Thin wrapper around WarrenNatsAdapter for backward compatibility.
pub struct NatsIngest {
    inner: warren_adapter::WarrenNatsAdapter,
}

impl NatsIngest {
    pub fn new(
        client: async_nats::Client,
        storage: Arc<RedbStorage>,
        embedding_service: Arc<FastEmbedService>,
        vector_index: Arc<StdRwLock<HnswIndex>>,
        graph_version: Arc<AtomicU64>,
    ) -> Self {
        Self {
            inner: warren_adapter::WarrenNatsAdapter::new(
                client,
                storage,
                embedding_service,
                vector_index,
                graph_version,
            ),
        }
    }

    pub async fn start(&self) -> Result<()> {
        self.inner.start().await
    }
}