feature/nanocld: introduced process trait

bin/nanocl/src/commands/cargo.rs

@@ -127,7 +127,7 @@ async fn exec_cargo_restart(
   let client = &cli_conf.client;
   for name in &opts.names {
     client
-      .restart_cargo(name, args.namespace.as_deref())
+      .restart_process("cargo", name, args.namespace.as_deref())
       .await?;
   }
   Ok(())

bin/nanocl/src/commands/job.rs

@@ -1,8 +1,7 @@
 use futures::StreamExt;
 use nanocl_error::io::{IoResult, FromIo, IoError};
 
-use nanocld_client::stubs::job::JobWaitQuery;
-use nanocld_client::stubs::process::ProcessLogQuery;
+use nanocld_client::stubs::process::{ProcessLogQuery, ProcessWaitQuery};
 
 use crate::utils;
 use crate::config::CliConfig;
@@ -86,10 +85,12 @@ async fn exec_job_wait(
 ) -> IoResult<()> {
   let client = &cli_conf.client;
   let mut stream = client
-    .wait_job(
+    .wait_process(
+      "job",
       &opts.name,
-      Some(&JobWaitQuery {
+      Some(&ProcessWaitQuery {
         condition: opts.condition.clone(),
+        namespace: None,
       }),
     )
     .await?;
@@ -102,7 +103,7 @@ async fn exec_job_wait(
     if resp.status_code != 0 {
       eprintln!(
         "Job container {}-{} ended with error code {}",
-        opts.name, resp.container_name, resp.status_code,
+        opts.name, resp.process_name, resp.status_code,
       );
       has_error = true;
     }

bin/nanocl/src/models/job.rs

@@ -2,7 +2,7 @@ use tabled::Tabled;
 use chrono::TimeZone;
 use clap::{Parser, Subcommand};
 
-use nanocld_client::stubs::job::{WaitCondition, JobSummary};
+use nanocld_client::stubs::{job::JobSummary, process::WaitCondition};
 
 use super::{DisplayFormat, GenericListOpts};