Enum ApplyEvent 

pub enum ApplyEvent {
    Change(Change),
    RelationChange(Box<RelationChange>),
}

One item in the apply buffer / transform window / ordered sink queue.

Sources may interleave row CDC and relation CDC; the apply engine preserves source order across both kinds through the same max_in_flight window.

RelationChange is boxed to keep the enum compact (RelationChange is substantially larger than Change).

Variants

Change(Change)

Row create / update / delete.

RelationChange(Box<RelationChange>)

Graph-edge create / update / delete (RelationChange).

Implementations

impl ApplyEvent

pub fn change(change: Change) -> Self

Wrap a row change.

pub fn relation_change(change: RelationChange) -> Self

Wrap a relation change.

pub fn is_change(&self) -> bool

Whether this is a row change.

pub fn is_relation_change(&self) -> bool

Whether this is a relation change.

Trait Implementations

impl Clone for ApplyEvent

fn clone(&self) -> ApplyEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ApplyEvent

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

Formats the value using the given formatter.