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
29
30
31
32
33

use crate::database::Database;
use crate::sync_types::{ApplyResult, ChangeSet, ConflictPolicies};
use contextdb_core::{Lsn, Result};

pub trait ChangeTracking {
    fn changes_since(&self, since_lsn: Lsn) -> ChangeSet;
    fn current_lsn(&self) -> Lsn;
}

pub trait ChangeApplication {
    fn apply_changes(&self, changes: ChangeSet, policies: &ConflictPolicies)
    -> Result<ApplyResult>;
}

impl ChangeTracking for Database {
    fn changes_since(&self, since_lsn: Lsn) -> ChangeSet {
        Database::changes_since(self, since_lsn)
    }

    fn current_lsn(&self) -> Lsn {
        Database::current_lsn(self)
    }
}

impl ChangeApplication for Database {
    fn apply_changes(
        &self,
        changes: ChangeSet,
        policies: &ConflictPolicies,
    ) -> Result<ApplyResult> {
        Database::apply_changes(self, changes, policies)
    }
}