queue_dispatch

nixfleet_control_plane::runtime::applier

Function queue_dispatch 

Source 
async fn queue_dispatch(
    ctx: &ApplierCtx<'_>,
    db: &Arc<Db>,
    now: DateTime<Utc>,
    host: &str,
    rollout: &RolloutId,
    target_closure: &str,
    soak_due_at: DateTime<Utc>,
)