Enum DifferentialEvent 

pub enum DifferentialEvent {
    Snapshot {
        subscriber_id: u64,
        view_name: String,
        snapshot_seq: u64,
        next_commit_seq: u64,
        rows: Vec<Row>,
    },
    Invalidation {
        subscriber_id: u64,
        view_name: String,
        commit_seq: u64,
    },
}

Connection-local differential stream events emitted to subscribers.

Variants

Snapshot

Initial bootstrap payload captured at a committed MVCC snapshot.

Fields

subscriber_id: u64

view_name: String

snapshot_seq: u64

next_commit_seq: u64

rows: Vec<Row>

Invalidation

Placeholder stream mode until table-level differential routing lands.

Fields

subscriber_id: u64

view_name: String

commit_seq: u64

Trait Implementations

impl Clone for DifferentialEvent

fn clone(&self) -> DifferentialEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DifferentialEvent

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

Formats the value using the given formatter.

impl PartialEq for DifferentialEvent

fn eq(&self, other: &DifferentialEvent) -> 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 DifferentialEvent

impl StructuralPartialEq for DifferentialEvent