Skip to main content

pull_machine_batches

kimetsu_brain::sync

Function pull_machine_batches 

Source 
pub fn pull_machine_batches(
    conn: &Connection,
    sync_dir: &Path,
    source_machine_id: &str,
    since_cursor: i64,
    dry_run: bool,
) -> KimetsuResult<(ImportSummary, i64)>
Expand description

Pull and import all batches from <sync_dir>/<source_machine_id>/ that come AFTER since_cursor. Updates the cursor in the registry.

Batches are files named <rowid>.jsonl; we sort numerically and process only those whose stem > since_cursor.