feat(dashboard): add nodes

Author: grampelberg

Cargo.lock

@@ -26,7 +26,7 @@ categories = ["command-line-interface", "development-tools", "virtualization"]
 ansi-to-tui = "6.0.0"
 async-trait = "0.1.82"
 base64 = "0.22.1"
-bon = "2.2.1"
+bon = "2.3.0"
 cata = { version = "0.1.1" }
 chrono = { version = "0.4.38", features = ["serde"] }
 clap = { version = "4.5.17", features = ["derive", "env"] }
@@ -47,10 +47,10 @@ itertools = "0.13.0"
 json-patch = "2.0.0"
 json_value_merge = "2.0.0"
 jsonwebtoken = "9.3.0"
-k8s-openapi = { version = "0.22.0", features = ["earliest"] }
-kube = { version = "0.94.1", features = ["derive", "runtime", "ws"] }
+k8s-openapi = { version = "0.23.0", features = ["earliest"] }
+kube = { version = "0.95.0", features = ["derive", "runtime", "ws"] }
 lazy_static = "1.5.0"
-local-ip-address = "0.6.2"
+local-ip-address = "0.6.3"
 mio = "1.0.2"
 ndarray = "0.16.1"
 pkcs8 = "0.10.2"

Cargo.toml

@@ -39,6 +39,13 @@
 
 ## TUI
 
+- Is it possible to get the kubelet logs?
+
+- Use SSH forwarding to get into the nodes.
+
+  - Does it make sense to do the `nsenter` trick for some use cases? This
+    requires privileged mode to work.
+
 - There's some kind of lag happening when scrolling aggressively (aka, holding
   down a cursor). It goes fine for ~10 items and then has a hitch in the
   rendering.

TODO.md

@@ -1,3 +1,4 @@
+mod agent;
 mod authz;
 mod dashboard;
 mod shell;
@@ -15,6 +16,7 @@ pub struct Dev {
 
 #[derive(Subcommand, Container)]
 enum DevCmd {
+    Agent(agent::Agent),
     Authz(authz::Authz),
     Dashboard(dashboard::Dashboard),
     Shell(shell::Shell),

src/cli/dev.rs

@@ -0,0 +1,22 @@
+use cata::{Command, Container};
+use clap::Parser;
+use eyre::Result;
+
+#[derive(Parser, Container)]
+pub struct Agent {}
+
+#[async_trait::async_trait]
+impl Command for Agent {
+    async fn run(&self) -> Result<()> {
+        let mut agent = russh_keys::agent::client::AgentClient::connect_env()
+            .await
+            .unwrap();
+        let mut identities = agent.request_identities().await.unwrap();
+        assert_eq!(identities.len(), 1);
+        let id = identities.pop().unwrap();
+
+        tracing::info!(key = ?id, "identity");
+
+        Ok(())
+    }
+}

src/cli/dev/agent.rs

@@ -1,6 +1,6 @@
 use std::time::Duration;
 
-use bon::builder;
+use bon::Builder;
 use eyre::{eyre, Report, Result};
 use futures::TryStreamExt;
 use lazy_static::lazy_static;
@@ -42,7 +42,7 @@ lazy_static! {
 static FPS: u16 = 10;
 pub static RENDER_INTERVAL: Duration = Duration::from_millis(1000 / FPS as u64);
 
-#[builder]
+#[derive(Builder)]
 pub struct Dashboard {
     client: kube::Client,
 }

src/dashboard.rs

@@ -2,6 +2,7 @@ pub mod age;
 pub mod container;
 pub mod file;
 pub mod install;
+pub mod node;
 pub mod pod;
 pub mod status;
 pub mod store;