Struct MemoryWriter 

pub struct MemoryWriter { /* private fields */ }

Writes memory data and provisions the memory database/tables/graph on demand.

Implementations

impl MemoryWriter

pub fn new( catalog: Arc<dyn Catalog>, format: Arc<dyn SegmentFormat>, embed: Arc<dyn EmbeddingBackend>, ) -> Self

Build a writer over the catalog + format engine. Backend-agnostic — works over the Postgres catalog (server) or the embedded SQLite catalog (kyma local); no direct DB pool is required.

pub fn database(&self) -> &str

pub async fn ensure_provisioned(&self) -> Result<()>

Ensure the memory database, both tables, and the memory graph registration exist. Fast-paths when the node table is already present, but first backfills any bi-temporal columns a pre-existing store is missing (non-destructive: historical extents null-fill on read).

pub async fn save(&self, m: &CreateMemory) -> Result<Uuid>

Embed + persist a new memory node plus a REFERENCES edge per reference. Returns the new memory uuid.

pub async fn save_as(&self, id: Uuid, m: &CreateMemory) -> Result<()>

Upsert a new version of an existing memory id (same id → latest-wins), re-embedding the redacted content. Used by topic-key upsert so a repeated save updates in place instead of creating a duplicate.

pub async fn link( &self, src_node_id: &str, dst_node_id: &str, rel_type: &str, realm: &str, target_namespace: Option<&str>, ) -> Result<()>

Append a single edge linking a memory node to another (possibly cross-graph) entity.

pub async fn append_node_rows(&self, node_rows: Vec<Value>) -> Result<()>

Append pre-built node rows (used by read-then-append mutations).

pub async fn append_edge_rows(&self, edge_rows: Vec<Value>) -> Result<()>

Append pre-built edge rows.

pub async fn embed_one(&self, text: &str) -> Result<Vec<f32>>

Embed a single text, returning its vector.