Skip to main content

Module postgres

Module postgres 

Source
Expand description

PostgreSQL storage backend for the incremental update system.

Provides a full-featured SQL backend for CLI deployment with:

  • Connection pooling via deadpool-postgres for concurrent access
  • Prepared statements for query plan caching and performance
  • Batch operations with transactional atomicity
  • Upsert semantics for idempotent fingerprint and edge updates

§Performance Targets

  • Single operations: <10ms p95 latency (Constitutional Principle VI)
  • Full graph load (1000 nodes): <50ms p95 latency

§Example

use thread_flow::incremental::backends::postgres::PostgresIncrementalBackend;

let backend = PostgresIncrementalBackend::new("postgresql://localhost/thread")
    .await
    .expect("Failed to connect to Postgres");

backend.run_migrations().await.expect("Migration failed");

Structs§

PostgresIncrementalBackend
PostgreSQL storage backend for the incremental update system.