Struct PostgresAdapter 

pub struct PostgresAdapter { /* private fields */ }

Postgres + pgvector storage adapter.

Implementations

impl PostgresAdapter

pub async fn connect(conn_str: &str) -> Result<Self>

Connect to Postgres, build the async pool + sync checkpoint store, and apply the schema. Uses the DeterministicEmbedder (1024-d) by default.

conn_str is a libpq URL or key=value connection string; it is read from DATABASE_URL / SMOOTH_AGENT_DATABASE_URL by Self::from_env.

Errors

Returns an error if the connection string is invalid, either pool fails to build, or schema migration fails.

pub async fn connect_with_embedder( conn_str: &str, embedder: Arc<dyn Embedder>, ) -> Result<Self>

As Self::connect but with a caller-supplied embedder. The adapter’s vector column width is taken from embedder.dim(), so a 1536-d GatewayEmbedder and the vector(1536) column always agree.

Errors

See Self::connect.

pub async fn from_env() -> Result<Self>

Connect using DATABASE_URL or SMOOTH_AGENT_DATABASE_URL (the latter wins if both are set).

Errors

Returns an error if neither env var is set, or if Self::connect fails.

pub fn embedding_dim(&self) -> usize

The embedding dimension this adapter’s knowledge_vectors column uses.

pub fn connector_config_store(&self) -> PgConnectorConfigStore

A Postgres-backed ConnectorConfigStore over this adapter’s pool (the connector_configs table). Cheap to build (clones the pool handle); make as many as you like.

pub fn settings_store(&self) -> PgSettingsStore

A Postgres-backed SettingsStore over this adapter’s pool (the agent_settings table).

pub fn indexing_store(&self) -> PgIndexingStore

A Postgres-backed IndexingStore over this adapter’s pool (the indexing_runs table).

pub fn memory( &self, organization_id: impl Into<String>, user_id: Option<String>, ) -> PgMemory

A Postgres-backed Memory over this adapter’s pool (the memories table), bound to one (organization_id, user_id) namespace — persistent, semantic, cross-thread agent memory (parity gap Phase 3 / SMOODEV-1470). Pass user_id = None for org-wide memory. Embeds with the adapter’s configured Embedder so memory and knowledge vectors share the same column width and hashing.

Cheap to build (clones pool + embedder handles); make one per (org, user) you serve.

Trait Implementations

impl Drop for PostgresAdapter

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl StorageAdapter for PostgresAdapter

fn create_conversation<'life0, 'async_trait>( &'life0 self, conversation: Conversation, ) -> Pin<Box<dyn Future<Output = Result<Conversation>> + Send + 'async_trait>>

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

Create (or idempotently return) a conversation.

fn get_conversation<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Conversation>>> + Send + 'async_trait>>

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

Fetch a conversation by id.

fn list_conversations_by_org<'life0, 'life1, 'async_trait>( &'life0 self, organization_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Conversation>>> + Send + 'async_trait>>

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

List conversations owned by an organization (newest first).

fn update_conversation<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, update: ConversationUpdate, ) -> Pin<Box<dyn Future<Output = Result<Conversation>> + Send + 'async_trait>>

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

Apply a partial update to a conversation; returns the updated row.

fn add_participant<'life0, 'async_trait>( &'life0 self, participant: Participant, ) -> Pin<Box<dyn Future<Output = Result<Participant>> + Send + 'async_trait>>

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

Add a participant to a conversation.

fn get_participant<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Participant>>> + Send + 'async_trait>>

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

Fetch a participant by id.

fn list_participants_by_conversation<'life0, 'life1, 'async_trait>( &'life0 self, conversation_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Participant>>> + Send + 'async_trait>>

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

List all participants in a conversation.

fn resolve_participant_by_external_id<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, conversation_id: &'life1 str, external_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Participant>>> + Send + 'async_trait>>

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

Resolve a participant within a conversation by its external identity (e.g. Supabase auth user id). Used to re-attach a returning user.

fn append_message<'life0, 'async_trait>( &'life0 self, message: Message, ) -> Pin<Box<dyn Future<Output = Result<Message>> + Send + 'async_trait>>

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

Append a message to a conversation.

fn get_message<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Message>>> + Send + 'async_trait>>

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

Fetch a message by id.

fn list_messages_by_conversation<'life0, 'async_trait>( &'life0 self, query: MessageQuery, ) -> Pin<Box<dyn Future<Output = Result<MessagePage>> + Send + 'async_trait>>

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

List messages in a conversation, paged.

fn create_session<'life0, 'async_trait>( &'life0 self, session: Session, ) -> Pin<Box<dyn Future<Output = Result<Session>> + Send + 'async_trait>>

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

Create a session (binds a conversation to a smooth-operator thread).

fn get_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Session>>> + Send + 'async_trait>>

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

Fetch a session by id.

fn update_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, update: SessionUpdate, ) -> Pin<Box<dyn Future<Output = Result<Session>> + Send + 'async_trait>>

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

Apply a partial update (status / counts / activity) to a session.

fn list_sessions_by_conversation<'life0, 'life1, 'async_trait>( &'life0 self, conversation_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Session>>> + Send + 'async_trait>>

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

List sessions attached to a conversation.

fn checkpoints(&self) -> Arc<dyn CheckpointStore>

The checkpoint store, ready to hand to a smooth-operator Agent via Agent::with_checkpoint_store. Synchronous trait — the engine calls it directly.

fn knowledge(&self) -> Arc<dyn KnowledgeBase>

The knowledge base, ready to hand to a smooth-operator AgentConfig via AgentConfig::with_knowledge. Synchronous trait.

fn knowledge_for_access(&self, access: &AccessContext) -> Arc<dyn KnowledgeBase>

An ACL-enforcing knowledge handle bound to the requester’s AccessContext: its query returns only documents the requester is entitled to read (org-public docs, docs the requester’s user id is on, or docs any of the requester’s groups is on). This is the handle the chat retrieval path (auto-injected context and the knowledge_search tool) MUST read through — see docs/ACCESS-CONTROL.md.