Struct PositionedChange 

pub struct PositionedChange<P> {
    pub change: Change,
    pub position: P,
}

A CDC / incremental row event plus the source position to advance after sink success.

Prefer PositionedEvent when the feed may also emit relation changes.

Fields

change: Change

Universal change to transform and apply.

position: P

Source position associated with this change (checkpoint candidate).

Implementations

impl<P> PositionedChange<P>

pub fn new(change: Change, position: P) -> Self

Construct a positioned change.

pub fn into_event(self) -> PositionedEvent<P>

Convert to the unified PositionedEvent form.

Trait Implementations

impl<P: Clone> Clone for PositionedChange<P>

fn clone(&self) -> PositionedChange<P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P: Debug> Debug for PositionedChange<P>

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

Formats the value using the given formatter.

impl<P> From<PositionedChange<P>> for PositionedEvent<P>

fn from(pc: PositionedChange<P>) -> Self

Converts to this type from the input type.