Skip to content
This repository has been archived by the owner on Mar 24, 2024. It is now read-only.

Commit

Permalink
Merge pull request #9 from golemcloud/update_client
Browse files Browse the repository at this point in the history
Update client
  • Loading branch information
senia-psm authored Feb 3, 2024
2 parents a476db2 + ae62857 commit fb6f1e4
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 18 deletions.
4 changes: 2 additions & 2 deletions Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,8 @@ clap = { version = "4.4.12", features = ["derive"] }
clap-verbosity-flag = "2.1.1"
derive_more = "0.99.17"
futures-util = "0.3.30"
golem-cloud-client = "0.0.52"
golem-gateway-client = "0.0.52"
golem-cloud-client = "0.0.55"
golem-gateway-client = "0.0.55"
golem-examples = "0.1.11"
http = "1.0.0"
indoc = "2.0.4"
Expand Down
24 changes: 8 additions & 16 deletions src/clients/worker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ impl<C: golem_cloud_client::api::WorkerClient + Sync + Send> WorkerClient for Wo

Ok(self
.client
.template_id_workers_post(
.post(
&template_id.0,
&WorkerCreationRequest {
name: name.0,
Expand All @@ -113,7 +113,7 @@ impl<C: golem_cloud_client::api::WorkerClient + Sync + Send> WorkerClient for Wo

let key = self
.client
.template_id_workers_worker_name_key_post(&template_id.0, &name.0)
.worker_name_key_post(&template_id.0, &name.0)
.await?;

Ok(key_api_to_cli(key))
Expand Down Expand Up @@ -141,7 +141,7 @@ impl<C: golem_cloud_client::api::WorkerClient + Sync + Send> WorkerClient for Wo

Ok(self
.client
.template_id_workers_worker_name_invoke_and_await_post(
.worker_name_invoke_and_await_post(
&template_id.0,
&name.0,
&invocation_key.0,
Expand All @@ -163,12 +163,7 @@ impl<C: golem_cloud_client::api::WorkerClient + Sync + Send> WorkerClient for Wo

let _ = self
.client
.template_id_workers_worker_name_invoke_post(
&template_id.0,
&name.0,
&function,
&parameters,
)
.worker_name_invoke_post(&template_id.0, &name.0, &function, &parameters)
.await?;
Ok(())
}
Expand All @@ -182,7 +177,7 @@ impl<C: golem_cloud_client::api::WorkerClient + Sync + Send> WorkerClient for Wo

let _ = self
.client
.template_id_workers_worker_name_interrupt_post(&template_id.0, &name.0, Some(false))
.worker_name_interrupt_post(&template_id.0, &name.0, Some(false))
.await?;
Ok(())
}
Expand All @@ -196,7 +191,7 @@ impl<C: golem_cloud_client::api::WorkerClient + Sync + Send> WorkerClient for Wo

let _ = self
.client
.template_id_workers_worker_name_interrupt_post(&template_id.0, &name.0, Some(true))
.worker_name_interrupt_post(&template_id.0, &name.0, Some(true))
.await?;
Ok(())
}
Expand All @@ -206,7 +201,7 @@ impl<C: golem_cloud_client::api::WorkerClient + Sync + Send> WorkerClient for Wo

let _ = self
.client
.template_id_workers_worker_name_delete(&template_id.0, &name.0)
.worker_name_delete(&template_id.0, &name.0)
.await?;
Ok(())
}
Expand All @@ -218,10 +213,7 @@ impl<C: golem_cloud_client::api::WorkerClient + Sync + Send> WorkerClient for Wo
) -> Result<WorkerMetadata, GolemError> {
info!("Getting worker {}/{} metadata", template_id.0, name.0);

Ok(self
.client
.template_id_workers_worker_name_get(&template_id.0, &name.0)
.await?)
Ok(self.client.worker_name_get(&template_id.0, &name.0).await?)
}

async fn connect(
Expand Down

0 comments on commit fb6f1e4

Please sign in to comment.