Module postgres 

Structs

PgConnectionConfig

Canonical Postgres connection parameters shared across sink, source CDC, batch executor, and frontend postgres_query table function. Each caller constructs this from its own user-facing config struct before invoking the shared helpers like create_pg_client or PostgresExternalTable::connect.

PostgresExternalTable

PostgresTablePrivilege 🔒

Enums

SslMode

Constants

CHECK_TABLE_PRIVILEGE_QUERY 🔒

DISCOVER_PGVECTOR_COLUMNS_QUERY 🔒

Discover pgvector columns with both atttypmod (dimension) and format_type text. vector(n) is stored as atttypmod = n, while dimension-less vector uses -1. We rely on this to keep user-defined type modifiers that are not preserved by sea-schema.

DISCOVER_PRIMARY_KEY_QUERY 🔒

SQL query to discover primary key columns directly from PostgreSQL system tables. This bypasses querying information_schema.table_constraints to avoid permission issues. Match pg_class and pg_namespace by exact catalog names instead of casting a constructed string to regclass, as unquoted regclass input folds mixed-case table names to lower case.

Functions

create_pg_client

create_pg_client_from_properties

discover_pgvector_dimensions

format_grant_table_privilege 🔒

format_grant_usage 🔒

format_pg_table_name 🔒

format_required_table_grants 🔒

parse_pgvector_dimension 🔒

pg_connection_config_from_properties

quote_pg_identifier 🔒

sea_type_to_pg_type 🔒

sea_type_to_rw_type