Struct RelayScanV1 

pub struct RelayScanV1 {
    pub cycle_end: u64,
    pub cursor: u64,
    pub blocked: Vec<Partition>,
}

Source-local scan progress. Every retained row at or below cursor belongs to a blocked target; new rows beyond cycle_end wait for the next cycle. The relay checkpoints this row under a guard on its prior value, atomically deleting delivered queue rows. Timer rescheduling is separate.

Fields

cycle_end: u64

Source os observed when the scan cycle started.

cursor: u64

Last inspected relay sequence, or zero before the first row.

blocked: Vec<Partition>

Sorted, unique retained targets in Partition order.

Trait Implementations

impl Clone for RelayScanV1

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 RelayScanV1

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

Formats the value using the given formatter.

impl Eq for RelayScanV1

impl PartialEq for RelayScanV1

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for RelayScanV1