Struct Ack 

pub struct Ack { /* private fields */ }

Confirms that one Change was durably processed downstream — written to the sink and checkpointed. Returned inside every change.

Each change carries a monotonically increasing sequence number. The mechanism only advances its durable resume point (for WAL, a replication slot’s confirmed_flush_lsn) to the highest contiguous confirmed sequence. Confirming out of order is therefore safe: a gap simply holds the resume point back until it is filled, and nothing already confirmed is re-sent.

Dropping an Ack without calling confirm does not confirm the change. It will be redelivered after a restart — this is the at-least-once guarantee.

Implementations

impl Ack

pub fn new(seq: u64, sink: Arc<dyn AckSink>) -> Self

Build an Ack for the change with sequence number seq. Called by a mechanism implementation as it emits each change.

pub fn confirm(self)

Confirm that this change was durably processed.

Trait Implementations

impl Debug for Ack

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

Formats the value using the given formatter.