diff --git a/agent/src/clone.rs b/agent/src/clone.rs index 5a4e836..f02fb83 100644 --- a/agent/src/clone.rs +++ b/agent/src/clone.rs @@ -205,7 +205,7 @@ pub async fn clone(target: &PathBuf, client: kube::Client, dist: &client::Distri pub async fn run(args: &Parameters) -> Result<()> { let client = get_client().await; - let mut distribs = DistribHandler::new(client.clone()); + let mut distribs = DistribHandler::new(&client.clone()); let dist = match distribs.get(args.name.as_str()).await { Ok(d) => d, Err(e) => { diff --git a/agent/src/destroy.rs b/agent/src/destroy.rs index a09cf3c..8f48e04 100644 --- a/agent/src/destroy.rs +++ b/agent/src/destroy.rs @@ -58,7 +58,7 @@ pub async fn destroy(src: &PathBuf, script: &mut script::Script, client: kube::C pub async fn run(args:&Parameters) -> Result<()> { let client = get_client().await; - let mut installs = InstallHandler::new(client.clone(), args.namespace.as_str()); + let mut installs = InstallHandler::new(&client.clone(), args.namespace.as_str()); let inst = match installs.get(args.name.as_str()).await {Ok(d) => d, Err(e) => { events::report(AGENT, client, events::from_error(&anyhow!("{e}")), events::get_empty_ref()).await.unwrap(); bail!("{e}"); diff --git a/agent/src/install.rs b/agent/src/install.rs index c0e81a1..8bdfa80 100644 --- a/agent/src/install.rs +++ b/agent/src/install.rs @@ -90,7 +90,7 @@ pub async fn install(src: &PathBuf, script: &mut script::Script, client: kube::C pub async fn run(args:&Parameters) -> Result<()> { let client = get_client().await; - let mut installs = InstallHandler::new(client.clone(), args.namespace.as_str()); + let mut installs = InstallHandler::new(&client.clone(), args.namespace.as_str()); let inst = match installs.get(args.name.as_str()).await {Ok(d) => d, Err(e) => { events::report(AGENT, client, events::from_error(&anyhow!("{e}")), events::get_empty_ref()).await.unwrap(); bail!("{e}"); diff --git a/agent/src/plan.rs b/agent/src/plan.rs index ac79774..afec311 100644 --- a/agent/src/plan.rs +++ b/agent/src/plan.rs @@ -57,7 +57,7 @@ pub async fn plan (src: &PathBuf, script: &mut script::Script, client: kube::Cli pub async fn run(args:&Parameters) -> Result<()> { let client = get_client().await; - let mut installs = InstallHandler::new(client.clone(), args.namespace.as_str()); + let mut installs = InstallHandler::new(&client.clone(), args.namespace.as_str()); let inst = match installs.get(args.name.as_str()).await {Ok(d) => d, Err(e) => { events::report(AGENT, client, events::from_error(&anyhow!("{e}")), events::get_empty_ref()).await.unwrap(); bail!("{e}"); diff --git a/agent/src/template.rs b/agent/src/template.rs index d65ad37..9a0f261 100644 --- a/agent/src/template.rs +++ b/agent/src/template.rs @@ -87,7 +87,7 @@ pub async fn template(src: PathBuf, dest: PathBuf, client: kube::Client, pub async fn run(args:&Parameters) -> Result<()> { let client = get_client().await; - let mut installs = InstallHandler::new(client.clone(), args.namespace.as_str()); + let mut installs = InstallHandler::new(&client.clone(), args.namespace.as_str()); let inst = match installs.get(args.name.as_str()).await{Ok(d) => d, Err(e) => { events::report(AGENT, client, events::from_error(&anyhow!("{e}")), events::get_empty_ref()).await.unwrap(); bail!("{e}");