Struct AppliedWatermark 

pub struct AppliedWatermark { /* private fields */ }

The consumer-side high-water mark — the maximum sequence this composition has applied (stream events or a reconcile sweep). Monotone: per-repo keys reorder nothing (the feed is global FIFO by offset), but a reconcile may apply a sequence a live event never carried; a watermark only advances, so the composition converges to the durable side’s own truth.

Process-local by design: the durable per-consumer cursor is the stream’s own checkpoint (monotone saves; restart resumes after the saved checkpoint), so a restart re-delivers only the window between apply and checkpoint — and per-seq idempotency is the consumer’s rule, exactly that re-application posture.

Implementations

impl AppliedWatermark

pub fn new() -> Arc<Self>

A fresh watermark at 0 (the whole table is unapplied — rows_since(0)).

pub fn observe(&self, seq: i64)

Raise the watermark to seq if it is higher (monotone).

pub fn get(&self) -> i64

The current high-water mark.

Trait Implementations

impl Default for AppliedWatermark

fn default() -> Self

Returns the “default value” for a type.