Struct SourceCheckpoint 

pub struct SourceCheckpoint {
    pub sequence: u64,
    pub source_position: Option<Bytes>,
}

Per-source checkpoint data.

Contains the monotonic sequence number and an optional opaque position that the source interprets to seek back into its native change stream (e.g., Postgres LSN, Kafka offset, EventHub sequence number).

Fields

sequence: u64

source_position: Option<Bytes>

Opaque position bytes for native stream resumption. Sources interpret these to seek back into their change stream.

Implementations

impl SourceCheckpoint

pub fn new(sequence: u64, source_position: Option<Bytes>) -> Self

Trait Implementations

impl Clone for SourceCheckpoint

fn clone(&self) -> SourceCheckpoint

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SourceCheckpoint

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

Formats the value using the given formatter.

impl PartialEq for SourceCheckpoint

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

impl StructuralPartialEq for SourceCheckpoint