contextdb-engine 0.3.4

Embedded database engine for agentic memory — relational, graph, and vector under unified MVCC transactions
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

use crate::composite_store::CompositeStore;
use crate::persistence::RedbPersistence;
use contextdb_core::{Result, RowId};
use contextdb_tx::{WriteSet, WriteSetApplicator};
use std::sync::Arc;

pub struct PersistentCompositeStore {
    inner: CompositeStore,
    persistence: Arc<RedbPersistence>,
}

impl PersistentCompositeStore {
    pub fn new(inner: CompositeStore, persistence: Arc<RedbPersistence>) -> Self {
        Self { inner, persistence }
    }
}

impl WriteSetApplicator for PersistentCompositeStore {
    fn apply(&self, ws: WriteSet) -> Result<()> {
        let log_entries = self.inner.build_change_log_entries(&ws);
        self.persistence.flush_data_with_logs(&ws, &log_entries)?;
        self.inner.apply(ws)
    }

    fn new_row_id(&self) -> RowId {
        self.inner.new_row_id()
    }
}