Struct KuzuStore 

pub struct KuzuStore { /* private fields */ }

Implementations

impl KuzuStore

pub fn open(path: &Path, machine_id: String) -> Result<Self>

pub fn in_memory(machine_id: String) -> Result<Self>

pub fn machine_id(&self) -> &str

pub fn diagnostic(&self) -> Result<String>

pub fn tombstone_exists(&self, id: Uuid) -> Result<bool>

impl KuzuStore

pub fn find_or_create_entity( &self, name: &str, entity_type: &str, ) -> Result<Entity>

pub fn memory_content_exists(&self, content_prefix: &str) -> Result<bool>

pub fn unconsolidated_memories(&self, limit: usize) -> Result<Vec<Memory>>

pub fn memories_created_between( &self, start: &DateTime<Utc>, end: &DateTime<Utc>, ) -> Result<Vec<Memory>>

pub fn mark_consolidated( &self, raw_id: Uuid, distilled_id: Uuid, model: &str, ) -> Result<()>

pub fn consolidation_count(&self) -> Result<usize>

pub fn delete_consolidated_raw(&self) -> Result<usize>

pub fn rebuild_vector_index(&self) -> Result<()>

pub fn clear_ingest_log(&self) -> Result<usize>

pub fn delete_memories_by_source(&self, source: &str) -> Result<usize>

pub fn is_file_ingested(&self, file_path: &str) -> Result<bool>

pub fn is_file_changed(&self, file_path: &str, file_hash: &str) -> Result<bool>

pub fn mark_ingested( &self, file_path: &str, file_hash: &str, memory_count: usize, source: &str, ) -> Result<()>

pub fn ingested_file_count(&self) -> Result<usize>

impl KuzuStore

pub fn get_conversation(&self, id: Uuid) -> Result<Option<Conversation>>

pub fn get_memory_with_embedding(&self, id: Uuid) -> Result<Option<Memory>>

pub fn sync_log_since(&self, after_seq: u64) -> Result<Vec<SyncEntry>>

pub fn apply_create_memory( &self, mem: &Memory, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn with_write_transaction<T>( &self, f: impl FnOnce(&Connection<'_>) -> Result<T>, ) -> Result<T>

pub fn apply_create_memory_on_tx( &self, conn: &Connection<'_>, mem: &Memory, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_create_conversation_on_tx( &self, conn: &Connection<'_>, conv: &Conversation, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_create_entity_on_tx( &self, conn: &Connection<'_>, entity: &Entity, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_create_relation_on_tx( &self, conn: &Connection<'_>, relation: &Relation, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn note_relation_created(&self, from_id: Uuid)

pub fn apply_update_memory( &self, incoming: &Memory, origin_machine_id: &str, origin_seq: i64, ) -> Result<(ApplyOutcome, Option<Memory>)>

pub fn apply_delete_memory( &self, node_id: &str, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_create_conversation( &self, conv: &Conversation, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_upsert_conversation( &self, conv: &Conversation, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_delete_conversation( &self, node_id: &str, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_create_entity( &self, entity: &Entity, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_upsert_entity( &self, entity: &Entity, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_delete_entity( &self, node_id: &str, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_create_relation( &self, relation: &Relation, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn apply_delete_relation( &self, node_id: &str, relation: Option<&Relation>, origin_machine_id: &str, origin_seq: i64, ) -> Result<ApplyOutcome>

pub fn sync_log_page( &self, after_seq: u64, limit: Option<usize>, ) -> Result<Vec<SyncEntry>>

pub fn get_sync_state(&self, peer_id: &str) -> Result<Option<SyncState>>

pub fn set_sync_state(&self, state: &SyncState) -> Result<()>

pub fn get_all_sync_states(&self) -> Result<Vec<SyncState>>

pub fn all_entities(&self) -> Result<Vec<Entity>>

pub fn memories_for_entity(&self, entity_id: Uuid) -> Result<Vec<Memory>>

pub fn unassociated_memories(&self) -> Result<Vec<Memory>>

pub fn related_entity_names(&self, entity_id: Uuid) -> Result<Vec<String>>

pub fn max_sync_seq(&self) -> Result<u64>

pub fn backfill_project_paths(&self) -> Result<u64>

pub fn memories_by_project_path( &self, project_path: &str, ) -> Result<Vec<Memory>>

pub fn all_memories_with_embeddings(&self) -> Result<Vec<Memory>>

pub fn backfill_sync_log(&self) -> Result<u64>

impl KuzuStore

pub fn upsert_machine(&self, id: &str, name: &str) -> Result<()>

pub fn get_machine_name(&self, id: &str) -> Result<Option<String>>

pub fn get_all_machines(&self) -> Result<HashMap<String, String>>

pub fn backfill_machine_id(&self, machine_id: &str) -> Result<u64>

pub fn register_machine(&self, identity: &MachineIdentity) -> Result<()>

Trait Implementations

impl Store for KuzuStore

fn store_memory(&self, memory: &Memory) -> Result<()>

fn get_memory(&self, id: Uuid) -> Result<Option<Memory>>

fn delete_memory(&self, id: Uuid) -> Result<()>

fn store_entity(&self, entity: &Entity) -> Result<()>

fn get_entity(&self, id: Uuid) -> Result<Option<Entity>>

fn find_entity_by_name(&self, name: &str) -> Result<Option<Entity>>

fn store_conversation(&self, conversation: &Conversation) -> Result<()>

fn store_relation(&self, relation: &Relation) -> Result<()>

fn get_relations( &self, node_id: Uuid, relation_type: Option<RelationType>, ) -> Result<Vec<Relation>>

fn vector_search( &self, embedding: &[f32], limit: usize, ) -> Result<Vec<(Memory, f32)>>

fn traverse( &self, start_id: Uuid, depth: u32, ) -> Result<Vec<(Memory, Vec<Relation>)>>

fn memories_by_source(&self, source: &str) -> Result<Vec<Memory>>

fn memories_by_type(&self, memory_type: MemoryType) -> Result<Vec<Memory>>

fn memories_needing_decay(&self, threshold_days: u32) -> Result<Vec<Memory>>

fn update_memory(&self, memory: &Memory) -> Result<()>

fn record_access(&self, memory: &Memory) -> Result<()>

fn text_search(&self, query: &str, limit: usize) -> Result<Vec<Memory>>

fn memory_count(&self) -> Result<usize>

fn all_memory_ids(&self) -> Result<Vec<Uuid>>

fn all_relations(&self) -> Result<Vec<Relation>>

impl Send for KuzuStore

impl Sync for KuzuStore