add progress reporting to stackablectl

Author: xeniape

Cargo.lock

@@ -31,6 +31,7 @@ directories = "5.0"
 dotenvy = "0.15"
 futures = "0.3"
 indexmap = { version = "2.2", features = ["serde"] }
+indicatif = "0.17.11"
 k8s-openapi = { version = "0.24", default-features = false, features = ["v1_32"] }
 kube = { version = "0.99", default-features = false, features = ["client", "rustls-tls", "ws", "socks5", "http-proxy"] }
 lazy_static = "1.5"
@@ -54,6 +55,7 @@ termion = "4.0"
 tokio = { version = "1.38", features = ["rt-multi-thread", "macros", "fs", "process", "io-std"] }
 tower-http = { version = "0.5", features = ["validate-request"] }
 tracing = "0.1"
+tracing-indicatif = "0.3.9"
 tracing-subscriber = "0.3"
 url = "2.5"
 urlencoding = "2.1.3"

Cargo.toml

@@ -31,11 +31,13 @@ stackable-operator.workspace = true
 tera.workspace = true
 tokio.workspace = true
 tracing.workspace = true
+tracing-indicatif.workspace = true
 url.workspace = true
 urlencoding.workspace = true
 utoipa = { workspace = true, optional = true }
 which.workspace = true
 futures.workspace = true
+indicatif.workspace = true
 
 [dev-dependencies]
 rstest.workspace = true

rust/stackable-cockpit/Cargo.toml

@@ -1,8 +1,10 @@
 use std::process::Stdio;
 
+use indicatif::ProgressStyle;
 use snafu::{ResultExt, Snafu};
 use tokio::process::Command;
-use tracing::{debug, instrument};
+use tracing::{Span, debug, instrument};
+use tracing_indicatif::span_ext::IndicatifSpanExt;
 
 type Result<T, E = Error> = std::result::Result<T, E>;
 
@@ -22,6 +24,7 @@ pub enum Error {
 #[instrument(skip_all)]
 pub async fn check_if_docker_is_running() -> Result<()> {
     debug!("Checking if Docker is running");
+    Span::current().pb_set_style(&ProgressStyle::with_template("").unwrap());
 
     if Command::new("docker")
         .arg("info")

rust/stackable-cockpit/src/engine/docker/mod.rs

@@ -1,8 +1,10 @@
 use std::process::Stdio;
 
+use indicatif::ProgressStyle;
 use snafu::{OptionExt, ResultExt, Snafu, ensure};
 use tokio::{io::AsyncWriteExt, process::Command};
-use tracing::{debug, info, instrument};
+use tracing::{Span, debug, info, instrument};
+use tracing_indicatif::span_ext::IndicatifSpanExt;
 
 use crate::{
     engine::{
@@ -67,6 +69,7 @@ impl Cluster {
     #[instrument(skip_all)]
     pub async fn create(&self) -> Result<()> {
         info!("Creating local cluster using kind");
+        Span::current().pb_set_style(&ProgressStyle::with_template("").unwrap());
 
         // Check if required binaries are present
         if let Some(binary) = binaries_present_with_name(&["docker", "kind"]) {
@@ -112,6 +115,7 @@ impl Cluster {
     #[instrument(skip_all)]
     pub async fn create_if_not_exists(&self) -> Result<()> {
         info!("Creating cluster if it doesn't exist using kind");
+        Span::current().pb_set_style(&ProgressStyle::with_template("").unwrap());
 
         if Self::check_if_cluster_exists(&self.name).await? {
             return Ok(());
@@ -134,16 +138,20 @@ impl Cluster {
     #[instrument(skip_all)]
     async fn check_if_cluster_exists(cluster_name: &str) -> Result<bool> {
         debug!("Checking if kind cluster exists");
+        Span::current().pb_set_style(&ProgressStyle::with_template("").unwrap());
 
         let output = Command::new("kind")
             .args(["get", "clusters"])
             .output()
             .await
             .context(CommandFailedToRunSnafu)?;
 
-        ensure!(output.status.success(), CommandErroredOutSnafu {
-            error: String::from_utf8_lossy(&output.stderr)
-        });
+        ensure!(
+            output.status.success(),
+            CommandErroredOutSnafu {
+                error: String::from_utf8_lossy(&output.stderr)
+            }
+        );
 
         let output = String::from_utf8_lossy(&output.stdout);
         Ok(output.lines().any(|name| name == cluster_name))

rust/stackable-cockpit/src/engine/kind/mod.rs

@@ -1,6 +1,8 @@
+use indicatif::ProgressStyle;
 use snafu::{ResultExt, Snafu};
 use tokio::process::Command;
-use tracing::{debug, info, instrument};
+use tracing::{Span, debug, info, instrument};
+use tracing_indicatif::span_ext::IndicatifSpanExt;
 
 use crate::{
     engine::docker::{self, check_if_docker_is_running},
@@ -44,6 +46,7 @@ impl Cluster {
     #[instrument(skip_all)]
     pub async fn create(&self) -> Result<(), Error> {
         info!("Creating local cluster using Minikube");
+        Span::current().pb_set_style(&ProgressStyle::with_template("").unwrap());
 
         // Check if required binaries are present
         if let Some(binary) = binaries_present_with_name(&["docker", "minikube"]) {
@@ -73,6 +76,7 @@ impl Cluster {
     #[instrument(skip_all)]
     pub async fn create_if_not_exists(&self) -> Result<(), Error> {
         info!("Creating cluster if it doesn't exist using Minikube");
+        Span::current().pb_set_style(&ProgressStyle::with_template("").unwrap());
 
         if Self::check_if_cluster_exists(&self.name).await? {
             return Ok(());
@@ -95,6 +99,7 @@ impl Cluster {
     #[instrument(skip_all)]
     async fn check_if_cluster_exists(cluster_name: &str) -> Result<bool, Error> {
         debug!("Checking if Minikube cluster exists");
+        Span::current().pb_set_style(&ProgressStyle::with_template("").unwrap());
 
         let output = Command::new("minikube")
             .arg("status")