Module postgres 

PostgreSQL connector-specific configuration and implementations. PostgreSQL connector-specific configuration and implementations.

Re-exports

pub use cdc::register_postgres_cdc_source;

pub use cdc::Lsn;

pub use cdc::PostgresCdcConfig;

pub use cdc::PostgresCdcSource;

pub use lookup::PostgresLookupSource;

pub use lookup::PostgresLookupSourceConfig;

pub use reference::PostgresReferenceTableSource;

pub use sink::PostgresSink;

pub use sink_config::PostgresSinkConfig;

pub use sink_config::WriteMode;

pub use sink_metrics::PostgresSinkMetrics;

Modules

cdc

PostgreSQL CDC source connector.

lookup

PostgreSQL on-demand lookup source for cache-miss fallback.

reference

PostgreSQL startup snapshot source for reference tables.

sink

PostgreSQL sink connector implementation.

sink_config

PostgreSQL sink connector configuration.

sink_metrics

PostgreSQL sink connector metrics.

types

Validated Arrow-to-PostgreSQL type contract for the sink.

Enums

SslMode

PostgreSQL connection security policy. Connection security for PostgreSQL connectors.

Functions

register_postgres_sink

Registers the PostgreSQL sink connector with the given registry.