Struct CompletionCursor 

pub struct CompletionCursor {
    pub epoch: FencingToken,
    pub turns: u64,
}

Comparable completion identity for one identity’s stream of turns.

Waiting for an agent’s next answer must never compare output TEXT. Two consecutive turns can legitimately produce byte-identical output (ACK twice is the production case that produced a phantom 962-second turn), and a text comparison then reports “no new turn” for the whole configured wait. This cursor is the comparable atom instead. It is never derived from output content, a content hash, a wall-clock timestamp, or a uuid regenerated per poll.

epoch is the identity’s lease FencingToken — the runtime-incarnation atom the LeaseProvider already issues, and which the bundled provider resumes strictly above the continuity store’s persisted high-water mark so it keeps advancing across process restarts. turns counts turns observed as completed within that incarnation.

Ordering is lexicographic (epoch, then turns), so the pair never regresses: a fresh incarnation always sorts above every cursor the previous one published. Turn counts are NOT comparable across incarnations, which is why callers classify with Self::progress_since rather than a bare > — an incarnation change is reported, not silently read as progress.

Fields

epoch: FencingToken

Lease incarnation this count belongs to.

turns: u64

Turns observed as completed within epoch.

Implementations

impl CompletionCursor

pub const fn start(epoch: FencingToken) -> Self

The zero cursor for epoch: no completed turn observed yet.

pub const fn new(epoch: FencingToken, turns: u64) -> Self

pub const fn advanced(self) -> Self

Advance by one completed turn within the same incarnation.

pub const fn rebased(self, epoch: FencingToken) -> Self

Re-anchor onto epoch when the identity’s lease incarnation moved on.

A stale or equal epoch leaves the cursor untouched, so a caller presenting an older token can never rewind what has been published.

pub const fn progress_since(self, baseline: Self) -> CompletionProgress

Classify this cursor against a baseline captured before a delivery.

Trait Implementations

impl Clone for CompletionCursor

fn clone(&self) -> CompletionCursor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for CompletionCursor

impl Debug for CompletionCursor

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

Formats the value using the given formatter.

impl Default for CompletionCursor

fn default() -> Self

The pre-lease cursor: epoch 0, no completed turns. Every real lease incarnation starts at token 1 or above, so this sorts below all of them.

impl<'de> Deserialize<'de> for CompletionCursor

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for CompletionCursor

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

Formats the value using the given formatter.

impl Eq for CompletionCursor

impl Hash for CompletionCursor

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for CompletionCursor

fn cmp(&self, other: &CompletionCursor) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for CompletionCursor

fn eq(&self, other: &CompletionCursor) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl PartialOrd for CompletionCursor

fn partial_cmp(&self, other: &CompletionCursor) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

fn lt(&self, other: &Rhs) -> bool

Tests less than (for self and other) and is used by the < operator.

fn le(&self, other: &Rhs) -> bool

Tests less than or equal to (for self and other) and is used by the <= operator.

fn gt(&self, other: &Rhs) -> bool

Tests greater than (for self and other) and is used by the > operator.

fn ge(&self, other: &Rhs) -> bool

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Serialize for CompletionCursor

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for CompletionCursor