aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/garage/admin.rs4
-rw-r--r--src/garage/cli/structs.rs4
2 files changed, 4 insertions, 4 deletions
diff --git a/src/garage/admin.rs b/src/garage/admin.rs
index e973cfe7..da324882 100644
--- a/src/garage/admin.rs
+++ b/src/garage/admin.rs
@@ -889,11 +889,11 @@ impl AdminRpcHandler {
.await;
Ok(AdminRpc::Ok("Scrub tranquility updated".into()))
}
- WorkerSetCmd::ResyncNWorkers { n_workers } => {
+ WorkerSetCmd::ResyncWorkerCount { worker_count } => {
self.garage
.block_manager
.resync
- .set_n_workers(n_workers)
+ .set_n_workers(worker_count)
.await?;
Ok(AdminRpc::Ok("Number of resync workers updated".into()))
}
diff --git a/src/garage/cli/structs.rs b/src/garage/cli/structs.rs
index cb085813..59e6e34f 100644
--- a/src/garage/cli/structs.rs
+++ b/src/garage/cli/structs.rs
@@ -540,8 +540,8 @@ pub enum WorkerSetCmd {
#[structopt(name = "scrub-tranquility", version = garage_version())]
ScrubTranquility { tranquility: u32 },
/// Set number of concurrent block resync workers
- #[structopt(name = "resync-n-workers", version = garage_version())]
- ResyncNWorkers { n_workers: usize },
+ #[structopt(name = "resync-worker-count", version = garage_version())]
+ ResyncWorkerCount { worker_count: usize },
/// Set tranquility of block resync operations
#[structopt(name = "resync-tranquility", version = garage_version())]
ResyncTranquility { tranquility: u32 },