Struct AimemDb 

pub struct AimemDb { /* private fields */ }

Shared Turso database handle.

Clone is cheap — the underlying Database is Arc-wrapped.

Implementations

impl AimemDb

pub async fn open(path: impl AsRef<Path>) -> DbResult<Self>

Open (or create) the AiMem DB at the given path and run schema migrations.

pub async fn memory() -> DbResult<Self>

Open an in-memory DB (for tests).

pub fn conn(&self) -> DbResult<Connection>

Acquire a write-capable connection from the database.

Kept write-capable for backward compatibility with existing callers.

pub async fn embedding_dimension(&self) -> DbResult<Option<usize>>

Return the configured embedding dimension, inferring it from existing stored vectors when upgrading older databases that predate metadata.

pub async fn embedding_profile(&self) -> DbResult<EmbeddingStoreProfile>

pub async fn assert_embedding_dimension(&self, dim: usize) -> DbResult<()>

Validate that a query vector matches the store dimension when known.

pub async fn assert_embedding_profile( &self, dim: usize, provider: &str, model: &str, ) -> DbResult<()>

pub async fn insert_drawer( &self, drawer: &Drawer, embedding: Option<&[f32]>, ) -> DbResult<bool>

Insert a drawer. Returns false if the ID already exists (no-op).

pub async fn insert_drawer_with_profile( &self, drawer: &Drawer, embedding: Option<&[f32]>, provider: &str, model: &str, ) -> DbResult<bool>

Insert a drawer and validate the embedding profile against store metadata.

pub async fn drawer_exists(&self, id: &str) -> DbResult<bool>

Check whether a drawer ID already exists.

pub async fn source_already_mined(&self, source_file: &str) -> DbResult<bool>

Check if a source file has already been mined.

pub async fn delete_drawer(&self, id: &str) -> DbResult<bool>

Delete a drawer by ID.

pub async fn find_drawers_by_exact_content( &self, content: &str, limit: usize, ) -> DbResult<Vec<Drawer>>

Find drawers whose content exactly matches the provided text.

pub async fn drawer_count(&self) -> DbResult<i64>

Total drawer count.

pub async fn taxonomy( &self, ) -> DbResult<(Vec<(String, i64)>, Vec<(String, i64)>)>

Return wing → count and room → count aggregates.

pub async fn fetch_drawers( &self, wing: Option<&str>, room: Option<&str>, limit: usize, ) -> DbResult<Vec<Drawer>>

Fetch all drawers in a wing (optionally filtered by room), ordered by filing time desc.

pub async fn upsert_entity(&self, entity: &Entity) -> DbResult<()>

Insert or replace an entity.

pub async fn insert_triple(&self, triple: &Triple) -> DbResult<bool>

Insert a triple (ignore if already exists).

pub async fn invalidate_triple( &self, subject: &str, predicate: &str, object: &str, ended: &str, ) -> DbResult<u64>

Mark a triple as expired (set valid_to).

Trait Implementations

impl Clone for AimemDb

fn clone(&self) -> AimemDb

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AimemDb

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.