Struct RangeCatchupPlan 

pub struct RangeCatchupPlan {
    pub range_id: u64,
    pub apply: Vec<usize>,
    pub rejected: Vec<RangeStreamReject>,
    pub resume: RangeStreamPosition,
    pub scanned: usize,
}

The result of filtering a slice of the shared logical stream down to one range’s catch-up work. apply holds indices into the input slice in ascending LSN order; resume is the position advanced past every applied record (persist it to make catch-up resumable); rejected lists the fenced records.

Fields

range_id: u64

apply: Vec<usize>

rejected: Vec<RangeStreamReject>

resume: RangeStreamPosition

scanned: usize

Implementations

impl RangeCatchupPlan

pub fn apply_count(&self) -> usize

Number of records selected for apply.

pub fn is_empty(&self) -> bool

Whether anything was selected to apply.

Trait Implementations

impl Clone for RangeCatchupPlan

fn clone(&self) -> RangeCatchupPlan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RangeCatchupPlan

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

Formats the value using the given formatter.

impl Eq for RangeCatchupPlan

impl PartialEq for RangeCatchupPlan

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RangeCatchupPlan