Struct PostgresFactStore 

pub struct PostgresFactStore { /* private fields */ }

Implementations

impl PostgresFactStore

pub fn new(pool: PgPool) -> Self

pub async fn open(database_url: &str) -> Result<Self, Error>

Open a connection pool from a database URL and return a store.

pub async fn migrate(&self) -> Result<(), Error>

Apply the DDL. Safe to call multiple times (uses IF NOT EXISTS).

Trait Implementations

impl FactStore for PostgresFactStore

fn insert_fact<'life0, 'async_trait>( &'life0 self, fact: Fact, ) -> Pin<Box<dyn Future<Output = Result<FactId, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Persist a new fact. The fact.id must be unique; implementations SHOULD return MemoryError::Database if a duplicate id is detected.

fn get_fact<'life0, 'async_trait>( &'life0 self, id: FactId, ) -> Pin<Box<dyn Future<Output = Result<Fact, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieve a single fact by id.

fn update_fact<'life0, 'async_trait>( &'life0 self, id: FactId, patch: FactPatch, ) -> Pin<Box<dyn Future<Output = Result<Fact, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Apply a partial patch to an existing fact. Only fields set to Some(…) in patch are updated.

fn list_facts<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 FactFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<Fact>, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

List facts matching the given filter.

fn invalidate_fact<'life0, 'async_trait>( &'life0 self, id: FactId, ) -> Pin<Box<dyn Future<Output = Result<(), MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Mark a fact as invalid as of now (sets invalid_at to the current timestamp). Does not delete the record; historical queries still see it.

fn delete_scope_data<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 Scope, ) -> Pin<Box<dyn Future<Output = Result<u64, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete ALL data (facts, entities, relationships) belonging to scope. This is a hard delete and is typically used for GDPR / right-to-erasure requests. Returns the number of facts deleted.

fn export<'life0, 'life1, 'async_trait>( &'life0 self, filter: &'life1 FactFilter, ) -> Pin<Box<dyn Future<Output = Result<Vec<Fact>, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Export all facts matching filter as a JSON-serialisable vector. Implementations SHOULD stream or batch internally to avoid loading unbounded data into memory when the result set is large.

fn import<'life0, 'async_trait>( &'life0 self, facts: Vec<Fact>, ) -> Pin<Box<dyn Future<Output = Result<u64, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Import a batch of facts (e.g. from a previous export). Existing facts with the same id SHOULD be skipped (upsert-or-ignore). Returns the number of facts successfully imported.

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<StoreStats, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return aggregate statistics for this store.

fn record_access<'life0, 'async_trait>( &'life0 self, id: FactId, ) -> Pin<Box<dyn Future<Output = Result<(), MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Record that a fact was accessed (increments access_count, updates last_accessed). Implementations MAY do this asynchronously / fire-and-forget; callers SHOULD NOT depend on the update being immediately visible.

fn keyword_search<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, query: &'life1 str, scope: &'life2 Scope, top_k: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Fact>, MemoryError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Full-text keyword search over fact text (BM25 ranking).