Struct LanceStore 

pub struct LanceStore { /* private fields */ }

LanceDB graph store with entities and relations tables.

Mutations use lancedb’s merge_insert directly. Graph traversal (find_connections) uses lance-graph Cypher queries.

Implementations

impl LanceStore

pub async fn open<F>(path: impl AsRef<Path>, embed_fn: F) -> Result<Self>

where F: Fn(&str) -> Result<Vec<f32>>,

Open or create the LanceDB database with entities and relations tables.

Detects v1 schema (entity table has agent column) and migrates to v2. Detects v2 schema (entities without vector column) and backfills embeddings using the provided embed function.

pub async fn upsert_entity(&self, row: &EntityRow<'_>) -> Result<()>

Upsert an entity by its id.

Note: when_matched_update_all resets created_at on update. LanceDB merge_insert does not support column exclusion, and a read-before-write adds a round-trip per upsert. updated_at tracks the last modification time; created_at is best-effort.

pub async fn search_entities( &self, query: &str, entity_type: Option<&str>, limit: usize, ) -> Result<Vec<EntityResult>>

Full-text search on entities with optional type filter.

pub async fn search_entities_semantic( &self, query_vector: &[f32], entity_type: Option<&str>, limit: usize, ) -> Result<Vec<EntityResult>>

Semantic search on entities by vector similarity.

pub async fn query_by_type( &self, entity_type: &str, limit: usize, ) -> Result<Vec<EntityResult>>

Query entities by type (no FTS, returns all matching).

pub async fn find_entity_by_key( &self, key: &str, ) -> Result<Option<EntityResult>>

Look up an entity by key.

pub async fn list_entities( &self, entity_type: Option<&str>, limit: usize, ) -> Result<Vec<EntityResult>>

List entities with optional type filter (no FTS).

pub async fn upsert_relation(&self, row: &RelationRow<'_>) -> Result<()>

Upsert a relation (deduplicated by source+relation+target).

pub async fn find_connections( &self, entity_id: &str, relation: Option<&str>, direction: Direction, limit: usize, ) -> Result<Vec<RelationResult>>

Find 1-hop connections from/to an entity using lance-graph Cypher.

pub async fn list_relations( &self, entity_id: Option<&str>, limit: usize, ) -> Result<Vec<RelationResult>>

List relations with optional entity filter (matches source or target).

pub async fn insert_journal( &self, agent: &str, summary: &str, vector: Vec<f32>, ) -> Result<()>

Insert a journal entry with its embedding vector.

pub async fn list_journals( &self, agent: Option<&str>, limit: usize, ) -> Result<Vec<JournalResult>>

Query most recent journal entries, optionally filtered by agent.

pub async fn recent_journals( &self, agent: &str, limit: usize, ) -> Result<Vec<JournalResult>>

Query most recent journal entries for an agent.