Skip to main content

parse_replication_message

laminar_connectors::cdc::postgres::postgres_io

Function parse_replication_message 

Source 
pub fn parse_replication_message(
    data: &[u8],
) -> Result<ReplicationMessage, ConnectorError>
Expand description

Parses a raw replication message from byte data.

The input should be the payload of a CopyData message (after stripping the CopyData framing).

§Wire Format

  • w (0x77): XLogData — 1 + 8 + 8 + 8 bytes header + variable payload
  • k (0x6B): PrimaryKeepalive — 1 + 8 + 8 + 1 = 18 bytes

§Errors

Returns ConnectorError::ReadError if the message is empty, has an unknown tag, or is truncated.