feat: Implement KubeClient::get_cluster_info (#90)

* refactor: Refactor kube.rs and move to utils

* feat: Implement KubeClient::get_cluster_info

* WIP. Filter to worker nodes is still missing

* Improve CLusterInfo

* Only count untainted nodes. Improve errror handling

* cleanup

* cleanup

* fix: docs

* Apply suggestions from code review

Co-authored-by: Techassi <git@techassi.dev>

* Update rust/stackable-cockpit/Cargo.toml

Co-authored-by: Techassi <git@techassi.dev>

* Update rust/helm-sys/Cargo.toml

Co-authored-by: Techassi <git@techassi.dev>

* Update rust/stackable-cockpit/src/platform/cluster.rs

Co-authored-by: Techassi <git@techassi.dev>

* improve docs

* bump op-rs

---------

Co-authored-by: Techassi <git@techassi.dev>

Author: sbernauer

Cargo.lock

@@ -3,40 +3,50 @@ members = ["rust/*", "web", "."]
 
 [workspace.package]
 version = "0.0.0-dev"
+authors = ["Stackable GmbH <info@stackable.tech>"]
+license = "OSL-3.0"
+edition = "2021"
+repository = "https://github.com/stackabletech/stackable-cockpit/"
 
 [workspace.dependencies]
-stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.42.2" }
-kube = { version = "0.82.2", default-features = false, features = [
-  "client",
-  "openssl-tls",
-] }
-k8s-openapi = { version = "0.18.0", default-features = false, features = [
-  "v1_26",
-] }
-tokio = { version = "1.27.0", features = ["rt-multi-thread", "macros", "fs"] }
+async-trait = "0.1"
+axum = { version = "0.6", features = ["http2", "headers"] }
+bcrypt = "0.15"
+clap = { version = "4.2.1", features = ["derive", "env"] }
+clap_complete = "4.2"
+comfy-table = { version = "7.0", features = ["custom_styling"] }
+dotenvy = "0.15"
+futures = "0.3"
+gobuild = "0.1.0-alpha.1"
+indexmap = { version = "2.0", features = ["serde"] }
+k8s-openapi = { version = "0.19", default-features = false, features = ["v1_27"] }
+kube = { version = "0.85", default-features = false, features = ["client", "openssl-tls"] }
+lazy_static = "1.4"
+nu-ansi-term = "0.49"
+phf = "0.11"
+phf_codegen = "0.11"
+rand = "0.8"
 reqwest = { version = "0.11.16", features = ["native-tls"] }
-serde = { version = "1.0.160", features = ["derive"] }
-indexmap = { version = "1.9.3", features = ["serde"] }
-clap = { version = "4.2.1", features = ["derive"] }
-tracing-subscriber = "0.3.17"
-utoipa-swagger-ui = "3.1.3"
-clap_complete = "4.2.0"
-phf_codegen = "0.11.1"
-async-trait = "0.1.68"
-lazy_static = "1.4.0"
-serde_json = "1.0.96"
-serde_yaml = "0.9.21"
-dotenvy = "0.15.7"
-tracing = "0.1.37"
-semver = "1.0.17"
-bcrypt = "0.14.0"
-utoipa = "3.3.0"
-axum = "0.6.18"
-snafu = "0.7.4"
-which = "4.4.0"
-tera = "1.18.1"
-sha2 = "0.10.7"
-rand = "0.8.5"
-phf = "0.11.1"
-url = "2.3.1"
-xdg = "2.4.1"
+semver = "1.0"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+serde_yaml = "0.9"
+sha2 = "0.10"
+snafu = "0.7"
+stackable-operator = { git = "https://github.com/stackabletech/operator-rs.git", tag = "0.46.0" }
+tera = "1.18"
+tokio = { version = "1.29.0", features = ["rt-multi-thread", "macros", "fs", "process"] }
+tower-http = "0.4"
+tracing = "0.1"
+tracing-subscriber = "0.3"
+url = "2.3"
+utoipa = "3.3"
+utoipa-swagger-ui = {version = "3.1", features = ["axum"] }
+uuid = { version = "1.4.0", features = ["v4"] }
+which = "4.4"
+xdg = "2.4"
+
+[patch."https://github.com/stackabletech/operator-rs.git"]
+# TODO: Switch to released version
+# We did not want to draw a release of operator-rs just for https://github.com/stackabletech/operator-rs/pull/634
+stackable-operator = { git = "https://github.com/stackabletech//operator-rs.git", ref = "0e1a60e16151048f7abade3e9733ff196a2b7e4d" }

Cargo.toml

@@ -1,11 +1,14 @@
 [package]
 name = "helm-sys"
-version = "0.0.0-dev"
-edition = "2021"
+description = "Rust wrapper around Helm Go library"
+version.workspace = true
+authors.workspace = true
+license.workspace = true
+edition.workspace = true
+repository.workspace = true
 publish = false
-links = "helm"
 
-# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+links = "helm"
 
 [build-dependencies]
-gobuild = "0.1.0-alpha.1"
+gobuild.workspace = true

extra/man/stackablectl.1

@@ -1,30 +1,35 @@
 [package]
 name = "stackable-cockpit"
+description = "Shared library which powers cockpitd and stackablectl"
 version.workspace = true
-edition = "2021"
+authors.workspace = true
+license.workspace = true
+edition.workspace = true
+repository.workspace = true
 publish = false
 
 [features]
 full = ["openapi"]
 openapi = ["dep:utoipa"]
 
 [dependencies]
-tokio = { workspace = true, features = ["process"] }
-utoipa = { workspace = true, optional = true }
-stackable-operator = { workspace = true }
 helm-sys = { path = "../helm-sys" }
-k8s-openapi = { workspace = true }
-serde_json = { workspace = true }
-serde_yaml = { workspace = true }
-indexmap = { workspace = true }
-reqwest = { workspace = true }
-tracing = { workspace = true }
-bcrypt = { workspace = true }
-snafu = { workspace = true }
-which = { workspace = true }
-serde = { workspace = true }
-tera = { workspace = true }
-kube = { workspace = true }
-rand = { workspace = true }
-sha2 = { workspace = true }
-url = { workspace = true }
+
+bcrypt.workspace = true
+indexmap.workspace = true
+k8s-openapi.workspace = true
+kube.workspace = true
+rand.workspace = true
+reqwest.workspace = true
+serde_json.workspace = true
+serde_yaml.workspace = true
+serde.workspace = true
+sha2.workspace = true
+snafu.workspace = true
+stackable-operator.workspace = true
+tera.workspace = true
+tokio.workspace = true
+tracing.workspace = true
+url.workspace = true
+utoipa = { workspace = true, optional = true }
+which.workspace = true

rust/helm-sys/Cargo.toml

@@ -1,6 +1,6 @@
 use serde::Serialize;
 
-use crate::cluster::NodeRole;
+use crate::engine::NodeRole;
 
 #[derive(Debug, Serialize)]
 #[serde(rename_all = "camelCase")]

rust/stackable-cockpit/Cargo.toml

@@ -5,8 +5,8 @@ use tokio::{io::AsyncWriteExt, process::Command};
 use tracing::{debug, info, instrument};
 
 use crate::{
-    cluster::{check_if_docker_is_running, kind::config::KindClusterConfig, DockerError},
     constants::DEFAULT_LOCAL_CLUSTER_NAME,
+    engine::{check_if_docker_is_running, kind::config::KindClusterConfig, DockerError},
     utils::check::binaries_present_with_name,
 };
 

rust/stackable-cockpit/src/cluster/docker/mod.rs renamed to rust/stackable-cockpit/src/engine/docker/mod.rs

@@ -3,8 +3,8 @@ use tokio::process::Command;
 use tracing::{debug, info, instrument};
 
 use crate::{
-    cluster::{check_if_docker_is_running, DockerError},
     constants::DEFAULT_LOCAL_CLUSTER_NAME,
+    engine::{check_if_docker_is_running, DockerError},
     utils::check::binaries_present,
 };