Enum ReplicationCopyData 

pub enum ReplicationCopyData {
    XLogData {
        wal_start: Lsn,
        wal_end: Lsn,
        server_time_micros: i64,
        data: Bytes,
    },
    KeepAlive {
        wal_end: Lsn,
        server_time_micros: i64,
        reply_requested: bool,
    },
}

Replication protocol CopyData message types.

During logical replication streaming, PostgreSQL sends data wrapped in CopyData messages. This enum represents the two primary message types:

• XLogData: Contains actual WAL data (transaction changes)
• KeepAlive: Server heartbeat, optionally requesting client response

Variants

XLogData

WAL data message containing transaction changes.

Fields

wal_start: Lsn

WAL position where this data starts

wal_end: Lsn

Current WAL end position on server (may be 0 for in-transaction messages)

server_time_micros: i64

Server timestamp in microseconds since 2000-01-01

data: Bytes

The actual pgoutput/wal2json/etc. payload

KeepAlive

Server heartbeat message.

Fields

wal_end: Lsn

Current WAL end position on server

server_time_micros: i64

Server timestamp in microseconds since 2000-01-01

reply_requested: bool

If true, server expects StandbyStatusUpdate reply

Implementations

impl ReplicationCopyData

pub fn is_xlog_data(&self) -> bool

Returns true if this is an XLogData message

pub fn is_keepalive(&self) -> bool

Returns true if this is a KeepAlive message

pub fn requires_reply(&self) -> bool

Returns true if this is a KeepAlive that requests a reply

Trait Implementations

impl Clone for ReplicationCopyData

fn clone(&self) -> ReplicationCopyData

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReplicationCopyData

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for ReplicationCopyData

fn eq(&self, other: &ReplicationCopyData) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ReplicationCopyData

impl StructuralPartialEq for ReplicationCopyData