Struct Ingest 

pub struct Ingest<R: GridRow> { /* private fields */ }

The single writer of the rows. Applies operations in order, diffs every replacement, writes change stamps and publishes snapshots.

Implementations

impl<R: GridRow> Ingest<R>

pub fn new(policy: HighlightPolicy, epoch: Instant) -> Self

Creates an empty store whose stamps are measured from epoch.

pub fn with_reload_policy( policy: HighlightPolicy, epoch: Instant, reload: Box<dyn ReloadPolicy<R>>, ) -> Self

Creates an empty store with a custom ReloadPolicy.

pub fn len(&self) -> usize

The number of live rows.

pub fn is_empty(&self) -> bool

Returns true if there are no rows.

pub fn hot_rows(&self) -> usize

The number of rows that currently own change stamps.

pub fn apply( &mut self, ops: impl IntoIterator<Item = Op<R>>, now: Instant, ) -> ChangeSet

Applies ops in order at now and returns what changed. Then drops the fading rows whose fade ended at now (ChangeSet::faded), even when ops is empty.

pub fn sweep(&mut self, now: Instant)

Frees the stamps of rows whose highlight is over. Runs at most twice per highlight duration and costs O(hot rows). A row with some hot stamps keeps its expired ones until it is written again.

pub fn snapshot(&self) -> Arc<StoreSnapshot<R>>

Publishes the current rows. Cheap: clones one Arc per page and per pinned band.