Skip to main content

spawn_worker

wombatkv_node::block_prefetch

Function spawn_worker 

Source 
pub fn spawn_worker(
    index: Arc<dyn MetadataIndex>,
    config: PrefetchConfig,
    emit: PrefetchEmit,
) -> PrefetchWorker
Expand description

Spawn the v1 / dry-run worker. Scores + logs, never fetches.

Retained for tests, diagnostic deployments, and the WMBT_KV_PREFETCH_DRY_RUN=1 escape hatch (configured by the embed-side start_prefetcher when the env is set).

index is held inside the worker via the supplied Arc clone, so the thread can read it without holding a reference to the outer struct. emit is invoked once per cycle with the plan; pass default_emit for the standard [MyelonInstr] event, or a test-side closure to capture the plan inline.