Struct ExtendingRangeSourceFactory 

pub struct ExtendingRangeSourceFactory { /* private fields */ }

Factory for ExtendingRangeSource. Differs from RangeSourceFactory in that end is an atomic that the extension policy may grow over the lifetime of the phase. global_extent() returns the CURRENT end so phase-status displays reflect any growth honestly.

Implementations

impl ExtendingRangeSourceFactory

pub fn new( name: &str, start: u64, initial_extent: u64, policy: Arc<dyn ExtensionPolicy>, ) -> Self

Build with an initial extent [start, start + initial_extent). The extension policy is consulted only when the cursor reaches the end — the first stride consumed produces indices in the initial range.

pub fn bounded(self, max_end: u64) -> Self

Cap growth at max_end (absolute ordinal, exclusive) — the partition-narrowing bound from SRD 71. The initial extent is clamped too, so a base chunk larger than the partition never reserves past it.

Trait Implementations

impl DataSourceFactory for ExtendingRangeSourceFactory

fn create_reader(&self) -> Box<dyn DataSource>

Create a new reader for a fiber.

fn schema(&self) -> &SourceSchema

Schema for all readers from this factory.

fn global_consumed(&self) -> u64

Global items consumed across all readers (for progress reporting).

fn global_extent(&self) -> Option<u64>

Known extent, if finite. Same as schema().extent but avoids clone.

fn replay_contract(&self) -> SourceReplayContract

Replay/addressability capability shared by readers from this factory.

fn rewind_for_poll(&self) -> bool

Rewind the factory’s shared cursor to the start so a subsequent create_reader() produces a fresh stream covering the same ordinal range: what a host that re-runs a source between poll rounds calls after each round exhausts it.