Trait ReloadPolicy 

pub trait ReloadPolicy<R: GridRow>: Send + 'static {
    // Required method
    fn resolve(&mut self, snapshot: Vec<Arc<R>>, live: Vec<Op<R>>) -> Vec<Op<R>>;
}

Resolves a reload: a fresh snapshot from the server (replace_all) against live operations producers wrote while it was loading.

The default is ReplayLive. A policy that knows row versions can drop live operations older than the snapshot instead. The live operations include Op::SetPinnedRows; Op::SetProgress is never buffered.

Required Methods

fn resolve(&mut self, snapshot: Vec<Arc<R>>, live: Vec<Op<R>>) -> Vec<Op<R>>

Returns the operations to apply, in order. Runs on the ingest task.

Implementors

impl<R: GridRow> ReloadPolicy<R> for ReplayLive