Struct PostgresBackend 

pub struct PostgresBackend { /* private fields */ }

Implementations

impl PostgresBackend

pub fn new(dsn_env: String) -> Self

pub async fn pool(&self) -> Result<&PgPool>

Lazily-initialized pool. Idempotent.

pub fn vector_metric_sql(metric: &str) -> Result<(&'static str, &'static str)>

Trait Implementations

impl BackendConn for PostgresBackend

type Db = Postgres

fn connect(&self) -> impl Future<Output = Result<()>> + Send

Force-initialize the connection pool. Idempotent — second call is a no-op. The DSN is sourced from the backend struct’s configuration (set when the backend is constructed), not from arguments to this method.

fn acquire_create_lock( &self, tx: &mut Transaction<'_, Postgres>, key: &str, ) -> impl Future<Output = Result<()>> + Send

fn table_exists( &self, tx: &mut Transaction<'_, Postgres>, db: &str, table: &str, ) -> impl Future<Output = Result<bool>> + Send

fn embedding_dim( &self, tx: &mut Transaction<'_, Postgres>, db: &str, table: &str, ) -> impl Future<Output = Result<Option<usize>>> + Send

impl BackendDialect for PostgresBackend

const NAME: &'static str = "postgres"

const SUPPORTS_UPSERT: bool = true

fn quote_ident(&self, name: &str) -> String

fn fq_table(&self, db: &str, table: &str) -> String

fn vector_type_ddl(&self, dim: usize) -> String

fn json_type_ddl(&self) -> String

fn tags_array_type_ddl(&self) -> String

fn text_pk_type_ddl(&self) -> String

fn timestamp_now_default_ddl(&self) -> String

fn vector_literal(&self, arr: &[f32]) -> String

fn json_literal(&self, obj: &Value) -> String

fn json_path_sql(&self, col_expr: &str, dotted_path: &str) -> String

fn upsert_clause(&self, key_cols: &[&str], update_cols: &[&str]) -> String

fn create_database_sql(&self, name: &str) -> String

fn add_column_if_not_exists_sql( &self, fq: &str, col: &str, type_ddl: &str, ) -> String

fn drop_table_sql(&self, fq: &str) -> String

fn emit_chunks_table_ddl( &self, fq: &str, cols: &[ColSpec], hnsw: bool, _dim: usize, _engine: Option<&str>, vector_metric: Option<&str>, ) -> Vec<String>