Struct ChangeEventBatch 

pub struct ChangeEventBatch {
    pub source: String,
    pub events: Vec<ChangeEvent>,
    pub first_sequence: u64,
    pub last_sequence: u64,
}

A batch of change events for coalesced delivery to subscribers.

Groups multiple ChangeEvents from the same source, with metadata about the sequence range for gap detection and resumption.

Fields

source: String

The source materialized view or query name.

events: Vec<ChangeEvent>

The events in this batch.

first_sequence: u64

First sequence number in this batch.

last_sequence: u64

Last sequence number in this batch (inclusive).

Implementations

impl ChangeEventBatch

pub fn new( source: String, events: Vec<ChangeEvent>, first_sequence: u64, last_sequence: u64, ) -> Self

Creates a new change event batch.

pub fn total_rows(&self) -> usize

Returns the total number of data rows across all events.

pub fn is_empty(&self) -> bool

Returns true if this batch contains no events.

pub fn len(&self) -> usize

Returns the number of events in this batch.

Trait Implementations

impl Clone for ChangeEventBatch

fn clone(&self) -> ChangeEventBatch

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChangeEventBatch

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

Formats the value using the given formatter.