Struct FleetLaneCursor 

pub struct FleetLaneCursor { /* private fields */ }

Caller-owned positions for every node lane of one ring type.

Implementations

impl FleetLaneCursor

pub const fn from_counter(initial_counter: u64) -> Self

Start every physical lane at the same lane-local counter.

This does not restore a multi-lane checkpoint: independently advanced lane positions must be preserved by retaining or cloning the cursor.

pub fn minimum_lane_next_counter(&self) -> u64

Numerical minimum of the lane-local next counters, including idle lanes.

Counters belong to independent physical lanes. This value is not a global cursor, event order, completion watermark, or multi-lane checkpoint. An idle lane at zero keeps the minimum at zero even after all available frames in other lanes have been read. Retain or clone this cursor to preserve each lane’s position; passing this minimum to Self::from_counter can replay already consumed frames.

Before lanes are initialized, returns the initial counter. Computing the minimum scans only caller-owned memory and does not poll the rings.

pub fn minimum_next_counter(&self) -> u64

👎Deprecated:

use minimum_lane_next_counter; this is not a global cursor or checkpoint

Numerical minimum of independent lane-local counters, not a global cursor.

Trait Implementations

impl Clone for FleetLaneCursor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FleetLaneCursor

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

Formats the value using the given formatter.

impl Eq for FleetLaneCursor

impl PartialEq for FleetLaneCursor

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FleetLaneCursor