Struct PositionedEvent 

pub struct PositionedEvent<P> {
    pub event: ApplyEvent,
    pub position: P,
}

A source event plus the position to advance after sink success.

Fields

event: ApplyEvent

Event to transform and apply.

position: P

Source position associated with this event (checkpoint candidate).

Implementations

impl<P> PositionedEvent<P>

pub fn new(event: ApplyEvent, position: P) -> Self

Construct a positioned event.

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

Positioned row change.

pub fn relation_change(change: RelationChange, position: P) -> Self

Positioned relation change.

Trait Implementations

impl<P: Clone> Clone for PositionedEvent<P>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P: Debug> Debug for PositionedEvent<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.