Struct PostgresConversationStore 

pub struct PostgresConversationStore { /* private fields */ }

PostgreSQL-backed append-only conversation and semantic-memory store.

Implementations

impl PostgresConversationStore

pub async fn ensure_schema(&self) -> Result<(), PostgresConversationStoreError>

Explicitly creates conversation, transcript, and semantic-memory tables.

Runtime operations never perform hidden migrations.

Errors

Propagates PostgreSQL DDL failures.

pub async fn ensure_semantic_memory_vector_schema( &self, dimensions: NonZeroU32, ) -> Result<(), PostgresConversationStoreError>

Adds a nullable pgvector column and cosine HNSW index for semantic memory.

Call this explicitly after Self::ensure_schema and before enabling a vector-configured store in production.

Errors

Propagates extension and DDL failures.

impl PostgresConversationStore

pub async fn connect( connection: &str, table: &str, ) -> Result<Self, PostgresConversationStoreError>

Connects without creating or changing schema.

Errors

Rejects unsafe table identifiers and propagates connection failures.

pub fn with_semantic_memory_embedder( self, embedder: Arc<dyn EmbeddingModel>, ) -> Self

Enables vector semantic-memory writes and searches for scoped operations.

Trait Implementations

impl ArtifactStore for PostgresConversationStore

fn put( &self, write: ArtifactWrite, ) -> ArtifactFuture<'_, Result<ArtifactRef, ArtifactError>>

Idempotently writes content and returns its integrity-bound reference.

fn get( &self, reference: &ArtifactRef, ) -> ArtifactFuture<'_, Result<Artifact, ArtifactError>>

Loads and verifies one artifact.

fn list( &self, scope: &ArtifactScope, after: Option<&str>, limit: u32, ) -> ArtifactFuture<'_, Result<ArtifactPage, ArtifactError>>

Lists one stable, bounded page inside one scope.

fn delete( &self, scope: &ArtifactScope, artifact_id: &str, ) -> ArtifactFuture<'_, Result<bool, ArtifactError>>

Idempotently deletes one artifact and its idempotency records.

fn purge_expired( &self, scope: &ArtifactScope, now_unix_ms: u64, limit: u32, ) -> ArtifactFuture<'_, Result<u32, ArtifactError>>

Deletes at most limit expired artifacts in one scope.

impl CheckpointStore for PostgresConversationStore

fn load(&self, id: CheckpointId) -> Result<Checkpoint, CheckpointError>

Loads the latest checkpoint revision.

fn compare_and_swap( &self, checkpoint: &Checkpoint, expected_revision: Option<u64>, ) -> Result<(), CheckpointError>

Creates or atomically replaces a checkpoint.

impl Clone for PostgresConversationStore

fn clone(&self) -> PostgresConversationStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConversationStore for PostgresConversationStore

fn create( &self, conversation_id: ConversationId, namespace: MemoryNamespace, ) -> ConversationStoreFuture<'_, Result<ConversationCreateOutcome, ConversationStoreError>>

Idempotently creates one empty conversation.

fn load_view( &self, conversation_id: ConversationId, namespace: MemoryNamespace, window: ConversationWindow, summary_batch: ConversationSummaryBatch, ) -> ConversationStoreFuture<'_, Result<ConversationView, ConversationStoreError>>

Loads a bounded view without deleting or rewriting transcript entries.

fn list_transcript( &self, conversation_id: ConversationId, namespace: MemoryNamespace, after: Option<ConversationSequence>, limit: ConversationWindow, ) -> ConversationStoreFuture<'_, Result<Vec<ConversationTranscriptEntry>, ConversationStoreError>>

Lists immutable transcript entries strictly after an optional sequence.

fn append( &self, namespace: MemoryNamespace, command: ConversationAppend, ) -> ConversationStoreFuture<'_, Result<ConversationVersion, ConversationStoreError>>

Atomically appends canonical messages under the expected version.

fn commit_summary( &self, namespace: MemoryNamespace, command: ConversationSummaryCommit, ) -> ConversationStoreFuture<'_, Result<ConversationSummary, ConversationStoreError>>

Monotonically replaces the lossy summary under the expected transcript version.

fn upsert_memory( &self, command: SemanticMemoryUpsert, ) -> ConversationStoreFuture<'_, Result<SemanticMemory, ConversationStoreError>>

Creates or compare-and-swaps one explicitly curated semantic memory.

fn search_memory( &self, query: SemanticMemoryQuery, ) -> ConversationStoreFuture<'_, Result<Vec<SemanticMemory>, ConversationStoreError>>

Searches semantic memory without reading transcript or journal storage.

fn upsert_memory_scoped( &self, command: SemanticMemoryUpsert, context: RetrievalContext, ) -> ConversationStoreFuture<'_, Result<SemanticMemoryUpsertOutcome, ConversationStoreError>>

Writes memory under an explicit cancellation/deadline scope.

fn search_memory_scoped( &self, query: SemanticMemoryQuery, context: RetrievalContext, ) -> ConversationStoreFuture<'_, Result<SemanticMemorySearchOutcome, ConversationStoreError>>

Searches memory under an explicit cancellation/deadline scope.

impl Debug for PostgresConversationStore

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

Formats the value using the given formatter.

impl DurableConversationStore for PostgresConversationStore

fn commit_durable_turn( &self, command: DurableConversationCommit, ) -> ConversationStoreFuture<'_, Result<ConversationVersion, ConversationStoreError>>

Atomically appends a transcript turn and advances its checkpoint.

impl EffectStore for PostgresConversationStore

fn load( &self, id: EffectId, ) -> Result<Option<EffectRecord>, EffectExecutorError>

Loads a record by effect identity.

fn find_by_idempotency( &self, capability_id: CapabilityId, key: &str, ) -> Result<Option<EffectRecord>, EffectExecutorError>

Resolves a logical effect by capability-scoped idempotency key.

fn compare_and_swap( &self, record: &EffectRecord, expected_revision: Option<u64>, ) -> Result<(), EffectExecutorError>

Creates or atomically replaces a record.