com/delete-slots TiFlash dm-master.tidb.pingcap.com/delete-slots DM Master dm-worker.tidb.pingcap.com/delete-slots DM Worker Open Source Conference 2022 Online/Spring 63 Autoscaling したい 負荷に応じて Pod の

struct Work { input: u32, respond_on: oneshot::Sender, } // キュー上の処理をリッスンして実行するワーカー。 async fn worker(mut work_queue: mpsc::Receiver) { let mut iterations = 0; loop { tokio::select! { Some(work) expect("failed waiting for response") } async fn main() { let (tx, rx) = mpsc::channel(10); spawn(worker(rx)); for i in 0..100 { let resp = do_work(&tx, i).await; println!("work result for iteration {i}: