Enum ReplicationEvent 

pub enum ReplicationEvent {
    KeepAlive {
        wal_end: Lsn,
        reply_requested: bool,
        server_time_micros: i64,
    },
    Begin {
        final_lsn: Lsn,
        xid: u32,
        commit_time_micros: i64,
    },
    XLogData {
        wal_start: Lsn,
        wal_end: Lsn,
        server_time_micros: i64,
        data: Bytes,
    },
    Commit {
        lsn: Lsn,
        end_lsn: Lsn,
        commit_time_micros: i64,
    },
    StoppedAt {
        reached: Lsn,
    },
}

Events emitted by the replication worker.

Variants

KeepAlive

Server heartbeat message.

Fields

wal_end: Lsn

Current server WAL end position

reply_requested: bool

Whether server requested a reply (already handled internally)

server_time_micros: i64

Server timestamp (microseconds since 2000-01-01)

Begin

Start of a transaction (pgoutput Begin message).

Fields

final_lsn: Lsn

xid: u32

commit_time_micros: i64

XLogData

WAL data containing transaction changes.

Fields

wal_start: Lsn

WAL position where this data starts

wal_end: Lsn

WAL end position (may be 0 for mid-transaction messages)

server_time_micros: i64

Server timestamp (microseconds since 2000-01-01)

data: Bytes

pgoutput-encoded change data

Commit

End of a transaction (pgoutput Commit message).

Fields

lsn: Lsn

end_lsn: Lsn

commit_time_micros: i64

StoppedAt

Emitted when stop_at_lsn has been reached.

After this event, no more events will be emitted and the replication stream will be closed.

Fields

reached: Lsn

The LSN that triggered the stop condition

Trait Implementations

impl Clone for ReplicationEvent

fn clone(&self) -> ReplicationEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationEvent

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

Formats the value using the given formatter.