diff options
| author | Alex Auvolat <lx@deuxfleurs.fr> | 2025-01-31 15:53:02 +0100 |
|---|---|---|
| committer | Alex Auvolat <lx@deuxfleurs.fr> | 2025-02-03 18:54:51 +0100 |
| commit | 7b9c047b113d78dacbece4670b8a1a1cbd771849 (patch) | |
| tree | 92e4241de8f981d7011eef3b3871e09175b28656 /src/garage/cli_v2/worker.rs | |
| parent | 10bbb26b303e7bd58ca3396009a66b70a1673c0f (diff) | |
| download | garage-7b9c047b113d78dacbece4670b8a1a1cbd771849.tar.gz garage-7b9c047b113d78dacbece4670b8a1a1cbd771849.zip | |
cli_v2: add local_api_request with crazy type bound
Diffstat (limited to 'src/garage/cli_v2/worker.rs')
| -rw-r--r-- | src/garage/cli_v2/worker.rs | 16 |
1 files changed, 4 insertions, 12 deletions
diff --git a/src/garage/cli_v2/worker.rs b/src/garage/cli_v2/worker.rs index 9db729ec..b94a4f68 100644 --- a/src/garage/cli_v2/worker.rs +++ b/src/garage/cli_v2/worker.rs @@ -27,15 +27,11 @@ impl Cli { pub async fn cmd_list_workers(&self, opt: WorkerListOpt) -> Result<(), Error> { let mut list = self - .api_request(ListWorkersRequest { - node: hex::encode(self.rpc_host), - body: LocalListWorkersRequest { - busy_only: opt.busy, - error_only: opt.errors, - }, + .local_api_request(LocalListWorkersRequest { + busy_only: opt.busy, + error_only: opt.errors, }) .await? - .into_single_response()? .0; list.sort_by_key(|info| { @@ -90,12 +86,8 @@ impl Cli { pub async fn cmd_worker_info(&self, tid: usize) -> Result<(), Error> { let info = self - .api_request(GetWorkerInfoRequest { - node: hex::encode(self.rpc_host), - body: LocalGetWorkerInfoRequest { id: tid as u64 }, - }) + .local_api_request(LocalGetWorkerInfoRequest { id: tid as u64 }) .await? - .into_single_response()? .0; let mut table = vec![]; |