Struct PostgresStore 

pub struct PostgresStore { /* private fields */ }

Default MemoryStore backed by Postgres.

Constructed via Self::new from an existing sea_orm::DatabaseConnection. The caller owns the connection’s lifecycle; this store does not pool or reconnect.

Implementations

impl PostgresStore

pub fn new(db: DatabaseConnection) -> Self

Builds a store from an existing Postgres connection.

pub fn db(&self) -> &DatabaseConnection

Returns the underlying Postgres connection.

Trait Implementations

impl Clone for PostgresStore

fn clone(&self) -> PostgresStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresStore

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

Formats the value using the given formatter.

impl MemoryStore for PostgresStore

async fn remember(&self, new: NewMemory) -> Result<Memory, StoreError>

Inserts a new memory and returns the persisted row.

async fn recall(&self, pid: &str) -> Result<Memory, StoreError>

Looks up a single memory by pid, returning all lifecycle states.

async fn find_by_pids(&self, pids: &[&str]) -> Result<Vec<Memory>, StoreError>

Fetches multiple memories by pid, returning only indexed rows.

async fn active_semantics_for_source( &self, source_pid: &str, ) -> Result<Vec<Memory>, StoreError>

Returns the active semantic rows derived from source_pid (epic 0011 Track B).

async fn extraction_stats( &self, filter: StatsFilter, ) -> Result<Vec<ExtractionStat>, StoreError>

Tallies extraction accuracy per (provider, model) over a scope slice.

async fn timeline( &self, scope: Scope, params: TimelineParams, ) -> Result<Vec<Memory>, StoreError>

Returns memories in scope ordered by created_at, with optional filters.

async fn memories_as_of( &self, scope: Scope, params: AsOfParams, ) -> Result<Vec<Memory>, StoreError>

Returns memories that were active in scope as of params.as_of.

async fn forget(&self, target: ForgetTarget) -> Result<Vec<String>, StoreError>

Deletes one memory or every memory in a scope, returning deleted pids.

async fn set_index_status( &self, pid: &str, status: IndexStatus, ) -> Result<(), StoreError>

Updates a memory’s index lifecycle state.

async fn find_failed(&self, limit: usize) -> Result<Vec<Memory>, StoreError>

Returns up to limit memories whose index lifecycle is failed.

async fn list_scopes(&self) -> Result<Vec<Scope>, StoreError>

Returns every distinct scope tuple present in the store.

async fn list_agent_ids( &self, org_id: &str, user_id: &str, ) -> Result<Vec<String>, StoreError>

Returns the distinct agent ids that have memories in the given org + user scope, sorted ascending.

async fn indexed_pids_in_scope( &self, scope: &Scope, ) -> Result<Vec<String>, StoreError>

Returns every indexed pid for the given scope.

async fn edit(&self, pid: &str, patch: EditPatch) -> Result<Memory, StoreError>

Mutates a memory in place. See EditPatch for the field semantics.

async fn set_category( &self, pid: &str, category: &str, ) -> Result<(), StoreError>

Sets a memory’s category label (epic 0011 ticket 0005).

async fn retire( &self, pid: &str, reason: RetirementReason, ) -> Result<(), StoreError>

Retires a memory with the given reason (epic 0011 Track B).

async fn supersede(&self, pid: &str, by_pid: &str) -> Result<(), StoreError>

Marks pid as superseded by by_pid.

async fn unsupersede(&self, pid: &str) -> Result<(), StoreError>

Clears the supersession marker on pid, restoring it to active state.

async fn supersession_at( &self, pid: &str, as_of: DateTime<FixedOffset>, ) -> Result<Option<String>, StoreError>

Returns the winner pid pid was superseded by as of as_of, or None.

async fn supersession_history( &self, pid: &str, ) -> Result<Vec<SupersessionEvent>, StoreError>

Returns every supersession decision against pid in chronological order.