Module postgres_io 

PostgreSQL logical replication I/O.

Enums

ReplicationMessage

A message received from the PostgreSQL replication stream.

Functions

build_replication_config

Builds a [pgwire_replication::ReplicationConfig] from a PostgresCdcConfig.

build_start_replication_query

Builds the START_REPLICATION SQL command.

connect

Connects to PostgreSQL as a regular (control-plane) connection.

drop_replication_slot

Drop a PostgreSQL logical replication slot.

encode_standby_status

Encodes a standby status update message.

ensure_replication_slot

Ensures the replication slot exists, creating it if necessary.

parse_replication_message

Parses a raw replication message from byte data.