Skip to main content

resolve_worker_sel

manycastr::orchestrator::task_distributor

Function resolve_worker_sel 

Source 
fn resolve_worker_sel(
    worker_ids: Vec<u32>,
    probing_workers: &[u32],
    dst: Address,
) -> Option<WorkerSel>
Expand description

Resolve a live target’s worker_ids into a worker selection: empty selects any worker (round-robin), [ALL_WORKERS] selects all probing workers, and anything else is an explicit set of worker IDs (sorted, deduplicated, and filtered to probing workers).

Returns None (drop the target) when none of the requested workers is probing.