Function mz_persist_client::internal::compact::start_prefetches

fn start_prefetches<T: Timestamp + Lattice + Codec64>(
    prefetch_budget_bytes: usize,
    runs: &mut Vec<(&Description<T>, VecDeque<CompactionPart<'_, T>>)>,
    shard_id: &ShardId,
    blob: &Arc<dyn Blob + Send + Sync>,
    metrics: &Arc<Metrics>,
    shard_metrics: &Arc<ShardMetrics>
)