Enum SourceEvent 

pub enum SourceEvent {
    Begin {
        final_lsn: Lsn,
        commit_ts: i64,
        xid: u32,
    },
    Relation(Arc<Relation>),
    Op(Op),
    Commit {
        commit_lsn: Lsn,
        end_lsn: Lsn,
        commit_ts: i64,
    },
    Keepalive {
        wal_end: Lsn,
    },
}

Ordered events produced by a replication source.

Variants

Begin

Fields

final_lsn: Lsn

LSN of the transaction’s commit record (equals Commit::commit_lsn).

commit_ts: i64

PostgreSQL timestamp (microseconds since 2000-01-01).

xid: u32

Relation(Arc<Relation>)

Op(Op)

Commit

Fields

commit_lsn: Lsn

end_lsn: Lsn

LSN after the commit record; this is what gets acknowledged.

commit_ts: i64

Keepalive

Server keepalive. Safe to acknowledge only between transactions.

Fields

wal_end: Lsn

Implementations

impl SourceEvent

pub fn byte_len(&self) -> usize

Approximate memory footprint, used for inflight accounting.

Trait Implementations

impl Clone for SourceEvent

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceEvent

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

Formats the value using the given formatter.

impl Eq for SourceEvent

impl PartialEq for SourceEvent

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SourceEvent