Skip to main content

Module decoder

faucet_stream::source::postgres_cdc::pgoutput

Module decoder

Available on crate features source-postgres-cdc and source-rest only.

Expand description

pgoutput wire-format decoder — turns raw bytes into Message values.

Structs§

PrimaryKeepAlive: PrimaryKeepAlive message (CopyData discriminator 'k').
XLogDataHeader: XLogData envelope header that precedes every pgoutput payload coming over the COPY BOTH stream (after the leading 'w' byte stripped by the caller).

Functions§

decode_message: Decode a single pgoutput message from the start of buf.