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

TcpKeepaliveConfig

TCP keepalive knobs for the long-lived Postgres client used by the sink. Lives in connector_common so both the sink config and the shared create_pg_client helper reference the same definition.

Enums

SslMode

Constants

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

parse_pgvector_dimension 🔒

pg_connection_config_from_properties

sea_type_to_pg_type 🔒

sea_type_to_rw_type