fluxreport dashboard (#211)

Signed-off-by: Daniel Guns <danbguns@gmail.com>

Author: dgunzy

CHANGELOG.md

@@ -7,6 +7,14 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+### Added
+- Cluster pulse dashboard (#195): `:pulse` answers "is my GitOps pipeline
+  healthy?" at a glance — ready/failed/suspended totals and per-kind counts
+  for the current namespace scope, the most recent failures with their
+  messages for fast triage, and the FluxReport's distribution, entitlement,
+  operator, and sync info alongside live controller pod health. Renders
+  instantly from the watch state (no fetch) and updates in real time.
+
 ### Added
 - Workload drill-down (#194): `Enter` on a graph workload group opens the
   workload list; `Enter` on a workload opens its detail — rollout status and

README.md

@@ -34,6 +34,7 @@ A [K9s](https://github.com/derailed/k9s)-inspired terminal UI for monitoring Flu
 - **Kubernetes Events** - Per-resource events in the describe view, plus a live `:events` feed for the current namespace or cluster
 - **Controller logs** - Stream any Flux controller pod's logs live with `:logs` (follow, search, bounded buffer)
 - **Workload drill-down** - Open a graph workload group to walk Deployments/StatefulSets/DaemonSets: rollout status, containers, pods, events, and pod logs
+- **Pulse dashboard** - `:pulse` shows cluster health at a glance: per-kind counts, recent failures, and Flux distribution info
 - **Graph visualization** - Visualize resource relationships and dependencies (Kustomization, HelmRelease, etc.)
 - **Reconciliation history** - View reconciliation history for resources that track it
 - **Favorites** - Mark frequently accessed resources for quick access

docs/content/user-guide/_index.md

@@ -97,6 +97,8 @@ Type these commands in command mode (press `:`):
 | `:fav`             | Alias for `:favorites`                   |
 | `:events`          | Live Kubernetes events feed              |
 | `:ev`              | Alias for `:events`                      |
+| `:pulse`           | Cluster health dashboard                 |
+| `:dashboard`       | Alias for `:pulse`                       |
 | `:logs`            | Controller log viewer (pod submenu)      |
 | `:logs <pod>`      | Stream a controller pod by name/prefix   |
 | `:skin <name>`     | Change theme/skin (direct)               |
@@ -287,6 +289,19 @@ resource list's MESSAGE column truncates.
 Events also appear in the describe view (`d`): each resource's describe output
 ends with a kubectl-style Events section listing that resource's recent events.
 
+### Pulse Dashboard (`:pulse`)
+
+An at-a-glance answer to "is my GitOps pipeline healthy?", updating in real
+time from the watch state:
+
+- Ready / failed / suspended totals and a per-kind breakdown, scoped to the
+  current namespace (or the whole cluster with `:ns all`)
+- The most recent failures with their reconcile messages, for fast triage
+  (jump to the full list with `:unhealthy`)
+- Flux distribution info from the FluxReport — version, install status,
+  entitlement, operator version, and sync source — plus live controller
+  pod health
+
 ### Controller Logs (`:logs`)
 
 Stream the logs of any Flux controller pod without leaving flux9s — the next

src/tui/app/core.rs

@@ -332,6 +332,25 @@ impl App {
         self.kube_events.clear();
     }
 
+    /// All watched resources in the current namespace scope — the pulse
+    /// dashboard's input. Ignores the list's type/text filters so the pulse
+    /// always shows the whole scope.
+    pub(crate) fn pulse_resources(&self) -> Vec<crate::watcher::ResourceInfo> {
+        let mut resources = self.state.all();
+        if let Some(ref namespace) = self.namespace {
+            resources.retain(|r| r.namespace == *namespace);
+        }
+        resources
+    }
+
+    /// The FluxReport object, when the Flux Operator publishes one.
+    pub(crate) fn flux_report_object(&self) -> Option<&serde_json::Value> {
+        self.resource_objects
+            .iter()
+            .find(|(key, _)| key.starts_with("FluxReport:"))
+            .map(|(_, obj)| obj)
+    }
+
     /// The live events feed filtered by the list filter (matches type, reason,
     /// object, source, namespace and message), newest first. Returns owned
     /// clones so callers can hold the list while mutating view state.
@@ -552,9 +571,11 @@ impl App {
                 .selected_resource_key
                 .as_deref()
                 .and_then(ResourceKey::parse),
-            // Logs and workload views show pods/workloads, which are not
-            // watched Flux resources.
-            View::Logs | View::WorkloadList | View::WorkloadDetail | View::Help => None,
+            // Logs, workload views and the pulse dashboard don't point at a
+            // single watched Flux resource.
+            View::Logs | View::WorkloadList | View::WorkloadDetail | View::Pulse | View::Help => {
+                None
+            }
         }
     }
 
@@ -704,18 +725,10 @@ impl App {
 
         match self.view_state.health_filter {
             HealthFilter::Healthy => {
-                resources.retain(|r| {
-                    let is_ready = r.ready.unwrap_or(true);
-                    let is_suspended = r.suspended.unwrap_or(false);
-                    is_ready && !is_suspended
-                });
+                resources.retain(crate::watcher::ResourceInfo::is_healthy);
             }
             HealthFilter::Unhealthy => {
-                resources.retain(|r| {
-                    let is_ready = r.ready.unwrap_or(true);
-                    let is_suspended = r.suspended.unwrap_or(false);
-                    !is_ready || is_suspended
-                });
+                resources.retain(|r| !r.is_healthy());
             }
             HealthFilter::All => {}
         }

src/tui/app/events.rs

@@ -26,6 +26,7 @@ const COMMAND_TABLE: &[(fn(&str) -> bool, CommandHandler)] = &[
     (commands::is_unhealthy_command, App::cmd_filter_unhealthy),
     (commands::is_favorites_command, App::cmd_show_favorites),
     (commands::is_events_command, App::cmd_show_events),
+    (commands::is_pulse_command, App::cmd_show_pulse),
     (commands::is_logs_command, App::cmd_show_logs),
     (commands::is_all_command, App::cmd_show_all),
 ];
@@ -653,6 +654,9 @@ impl App {
                     self.logs_after_workload_load = false;
                     self.view_state.text_search.clear();
                     self.view_state.current_view = View::WorkloadList;
+                } else if self.view_state.current_view == View::Pulse {
+                    self.view_state.text_search.clear();
+                    self.view_state.current_view = View::ResourceList;
                 }
             }
             _ => {}
@@ -1130,6 +1134,11 @@ impl App {
                 self.view_state.current_view = View::WorkloadList;
                 None
             }
+            View::Pulse => {
+                self.view_state.text_search.clear();
+                self.view_state.current_view = View::ResourceList;
+                None
+            }
             View::Help => {
                 self.view_state.current_view = View::ResourceList;
                 None
@@ -1715,6 +1724,13 @@ impl App {
         self.reset_list_position();
     }
 
+    /// `:pulse` — open the cluster pulse dashboard.
+    fn cmd_show_pulse(&mut self, _cmd: &str) {
+        self.view_state.pulse_scroll_offset = 0;
+        self.view_state.text_search.clear();
+        self.view_state.current_view = View::Pulse;
+    }
+
     /// `:logs [pod]` — stream a Flux controller pod's logs. Without an
     /// argument, opens a submenu of the discovered controller pods; with one,
     /// matches a pod by exact name or unique prefix.
@@ -2852,4 +2868,19 @@ mod tests {
         assert!(app.view_state.submenu_state.is_none(), "submenu closes");
         assert!(app.ui_state.command_mode, "command mode opens");
     }
+
+    #[test]
+    fn pulse_command_opens_dashboard_and_esc_returns() {
+        let mut app = create_test_app(false);
+        add_resource(&mut app);
+
+        app.ui_state.command_buffer = "pulse".to_string();
+        let result = app.execute_command();
+
+        assert_eq!(result, None);
+        assert_eq!(app.view_state.current_view, View::Pulse);
+
+        app.handle_key(make_key(KeyCode::Esc));
+        assert_eq!(app.view_state.current_view, View::ResourceList);
+    }
 }

src/tui/app/rendering.rs

@@ -515,6 +515,23 @@ impl App {
                         &self.theme,
                     );
                 }
+                View::Pulse => {
+                    let resources = self.pulse_resources();
+                    // Cloned so the &self method borrow ends before the
+                    // &mut view_state borrows below.
+                    let flux_report = self.flux_report_object().cloned();
+                    views::render_pulse(
+                        f,
+                        area,
+                        &resources,
+                        flux_report.as_ref(),
+                        &self.controller_pods.get_all_pods(),
+                        self.namespace.as_deref(),
+                        &mut self.view_state.pulse_scroll_offset,
+                        &mut self.view_state.text_search,
+                        &self.theme,
+                    );
+                }
                 View::Help => {
                     render_help(f, area, &self.theme, self.namespace_hotkeys());
                 }

src/tui/app/state.rs

@@ -31,6 +31,9 @@ pub enum View {
     /// One workload's rollout status, containers, pods, and events (#194).
     /// Back returns to the workload list.
     WorkloadDetail,
+    /// Cluster pulse dashboard (#195): per-kind health counts, recent
+    /// failures, and FluxReport distribution info. Opened with `:pulse`.
+    Pulse,
     #[allow(dead_code)] // Reserved for future alternative help view implementation
     Help,
 }
@@ -49,6 +52,7 @@ impl View {
             View::ResourceHistory => Some(&mut vs.history_scroll_offset),
             View::Logs => Some(&mut vs.log_scroll_offset),
             View::WorkloadDetail => Some(&mut vs.workload_scroll_offset),
+            View::Pulse => Some(&mut vs.pulse_scroll_offset),
             _ => None,
         }
     }
@@ -69,6 +73,7 @@ impl View {
                 | View::ResourceTrace
                 | View::Logs
                 | View::WorkloadDetail
+                | View::Pulse
         )
     }
 
@@ -211,6 +216,8 @@ pub struct ViewState {
     pub log_scroll_offset: usize,
     /// Scroll offset for the workload detail view
     pub workload_scroll_offset: usize,
+    /// Scroll offset for the pulse dashboard
+    pub pulse_scroll_offset: usize,
     /// Where Back from the log view returns to, when logs were opened from
     /// somewhere other than a root list view (e.g. a workload's pods).
     /// Consumed on Back; `None` falls back to `previous_list_view`.
@@ -259,6 +266,7 @@ impl Default for ViewState {
             history_scroll_offset: 0,
             log_scroll_offset: 0,
             workload_scroll_offset: 0,
+            pulse_scroll_offset: 0,
             logs_back_view: None,
             workload_rows: Vec::new(),
             graph_scroll_offset: 0,
@@ -617,6 +625,17 @@ mod tests {
                 .scroll_offset_mut(&mut ViewState::default())
                 .is_some()
         );
+
+        // The pulse dashboard behaves the same way: a root-level,
+        // searchable, line-scrolled text view.
+        assert!(!View::Pulse.is_nested_view());
+        assert!(!View::Pulse.is_list_view());
+        assert!(View::Pulse.is_text_search_view());
+        assert!(
+            View::Pulse
+                .scroll_offset_mut(&mut ViewState::default())
+                .is_some()
+        );
     }
 
     #[test]

src/tui/commands.rs

@@ -21,6 +21,10 @@ pub const APP_COMMANDS: &[Command] = &[
         name: "events",
         takes_args: false,
     },
+    Command {
+        name: "pulse",
+        takes_args: false,
+    },
     Command {
         name: "logs",
         takes_args: true,
@@ -148,6 +152,12 @@ pub fn is_events_command(cmd: &str) -> bool {
     cmd_lower == "events" || cmd_lower == "event" || cmd_lower == "ev"
 }
 
+/// Check if command opens the pulse dashboard
+pub fn is_pulse_command(cmd: &str) -> bool {
+    let cmd_lower = cmd.to_lowercase();
+    cmd_lower == "pulse" || cmd_lower == "dashboard"
+}
+
 /// Check if command opens the controller log viewer (with or without a pod argument)
 pub fn is_logs_command(cmd: &str) -> bool {
     let cmd_lower = cmd.to_lowercase();

src/tui/views/help.rs

@@ -57,6 +57,7 @@ pub fn render_help(f: &mut Frame, area: Rect, theme: &Theme, namespace_hotkeys:
         (":favorites", "View favorites"),
         (":fav", "View favorites"),
         (":events", "Live Kubernetes events feed"),
+        (":pulse", "Cluster health dashboard"),
         (":logs [pod]", "Stream controller logs"),
         (":q", "Quit application"),
     ];

src/tui/views/mod.rs

@@ -16,6 +16,7 @@ mod help;
 mod helpers;
 mod history;
 mod logs;
+mod pulse;
 mod quit_confirm;
 pub mod resource_fields;
 mod resource_list;
@@ -39,6 +40,7 @@ pub use help::*;
 pub use helpers::*;
 pub use history::*;
 pub use logs::*;
+pub use pulse::*;
 pub use quit_confirm::*;
 pub use resource_fields::*;
 pub use resource_list::*;