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,
    },
    Message {
        transactional: bool,
        lsn: Lsn,
        prefix: String,
        content: Bytes,
    },
    StoppedAt {
        reached: Lsn,
    },
}

Re-export so downstream modules (stream.rs, Task 9) can import the event type without depending on pgwire_replication directly. 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

Message

Logical decoding message emitted via pg_logical_emit_message().

Transactional messages are delivered only after the enclosing transaction commits. Non-transactional messages are delivered immediately.

Fields

transactional: bool

Whether the message was emitted inside a transaction.

lsn: Lsn

LSN of the message in the WAL.

prefix: String

Application-defined message prefix (e.g. "myapp.checkpoint").

content: Bytes

Raw message content bytes.

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<(), Error>

Formats the value using the given formatter.