Skip to main content

run

reifydb_engine::backfill

Function run 

Source 
pub fn run<'a>(
    services: &Arc<Services>,
    tx: Transaction<'a>,
    sources: &BTreeSet<ObjectId>,
    batch_size: NonZeroU64,
    consume: impl FnMut(&mut TransactionScan<'a>, Change) -> Result<()>,
) -> Result<()>