Skip to main content

decode_pgoutput_message

krabka_connect_postgres::pgoutput

Function decode_pgoutput_message 

Source 
pub fn decode_pgoutput_message(
    bytes: &[u8],
    lsn: PgLsn,
    txid: Option<TransactionId>,
) -> Result<DecodedMessage, PostgresConnectError>
Expand description

ยงErrors

Returns an error when configuration is invalid, protocol encoding fails, the broker rejects the request, or transport I/O fails.