Struct RangeSourceFactory 

pub struct RangeSourceFactory { /* private fields */ }

Factory for range sources. Shared atomic cursor distributes ordinals across fibers.

Implementations

impl RangeSourceFactory

pub fn new(start: u64, end: u64) -> Self

Create a range source from [start, end).

pub fn named(name: &str, start: u64, end: u64) -> Self

Create a range source with a named schema.

Trait Implementations

impl DataSourceFactory for RangeSourceFactory

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 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.

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

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