Complete disk collector rewrite with clean architecture

Replaced complex disk collector with simple lsblk → df → group workflow.
Supports both physical drives and mergerfs pools with unified metrics.
Eliminates configuration complexity through pure auto-discovery.

- Clean discovery pipeline using lsblk and df commands
- Physical drive grouping with filesystem children
- MergerFS pool detection with parity heuristics
- Unified metric generation for consistent dashboard display
- SMART data collection for temperature, wear, and health

CLAUDE.md

@@ -144,6 +144,130 @@ nix-build --no-out-link -E 'with import <nixpkgs> {}; fetchurl {
 - **Workspace builds**: `nix-shell -p openssl pkg-config --run "cargo build --workspace"`
 - **Clean compilation**: Remove `target/` between major changes
 
+## Enhanced Storage Pool Visualization
+
+### Auto-Discovery Architecture
+
+The dashboard uses automatic storage discovery to eliminate manual configuration complexity while providing intelligent storage pool grouping.
+
+### Discovery Process
+
+**At Agent Startup:**
+1. Parse `/proc/mounts` to identify all mounted filesystems
+2. Detect MergerFS pools by analyzing `fuse.mergerfs` mount sources
+3. Identify member disks and potential parity relationships via heuristics
+4. Store discovered storage topology for continuous monitoring
+5. Generate pool-aware metrics with hierarchical relationships
+
+**Continuous Monitoring:**
+- Use stored discovery data for efficient metric collection
+- Monitor individual drives for SMART data, temperature, wear
+- Calculate pool-level health based on member drive status
+- Generate enhanced metrics for dashboard visualization
+
+### Supported Storage Types
+
+**Single Disks:**
+- ext4, xfs, btrfs mounted directly
+- Individual drive monitoring with SMART data
+- Traditional single-disk display for root, boot, etc.
+
+**MergerFS Pools:**
+- Auto-detect from `/proc/mounts` fuse.mergerfs entries
+- Parse source paths to identify member disks (e.g., "/mnt/disk1:/mnt/disk2")
+- Heuristic parity disk detection (sequential device names, "parity" in path)
+- Pool health calculation (healthy/degraded/critical)
+- Hierarchical tree display with data/parity disk grouping
+
+**Future Extensions Ready:**
+- RAID arrays via `/proc/mdstat` parsing
+- ZFS pools via `zpool status` integration
+- LVM logical volumes via `lvs` discovery
+
+### Configuration
+
+```toml
+[collectors.disk]
+enabled = true
+auto_discover = true  # Default: true
+# Optional exclusions for special filesystems
+exclude_mount_points = ["/tmp", "/proc", "/sys", "/dev"]
+exclude_fs_types = ["tmpfs", "devtmpfs", "sysfs", "proc"]
+```
+
+### Display Format
+
+```
+Storage:
+● /srv/media (mergerfs (2+1)):
+  ├─ Pool Status: ● Healthy (3 drives)
+  ├─ Total: ● 63% 2355.2GB/3686.4GB
+  ├─ Data Disks:
+  │  ├─ ● sdb T: 24°C
+  │  └─ ● sdd T: 27°C
+  └─ Parity: ● sdc T: 24°C
+● /:
+  ├─ ● nvme0n1 W: 13%
+  └─ ● 7% 14.5GB/218.5GB
+```
+
+### Implementation Benefits
+
+- **Zero Configuration**: No manual pool definitions required
+- **Always Accurate**: Reflects actual system state automatically
+- **Scales Automatically**: Handles any number of pools without config changes
+- **Backwards Compatible**: Single disks continue working unchanged
+- **Future Ready**: Easy extension for additional storage technologies
+
+### Current Status (v0.1.100)
+
+**✅ Completed:**
+- Auto-discovery system implemented and deployed
+- `/proc/mounts` parsing with smart heuristics for parity detection
+- Storage topology stored at agent startup for efficient monitoring
+- Universal zero-configuration for all hosts (cmbox, steambox, simonbox, srv01, srv02, srv03)
+- Enhanced pool health calculation (healthy/degraded/critical)
+- Hierarchical tree visualization with data/parity disk separation
+
+**🔄 In Progress - Complete Disk Collector Rewrite:**
+
+The current disk collector has grown complex with mixed legacy/auto-discovery approaches. Planning complete rewrite with clean, simple workflow supporting both physical drives and mergerfs pools.
+
+**New Clean Architecture:**
+
+**Discovery Workflow:**
+1. **`lsblk`** to detect all mount points and backing devices
+2. **`df`** to get filesystem usage for each mount point
+3. **Group by physical drive** (nvme0n1, sda, etc.)
+4. **Parse `/proc/mounts`** for mergerfs pools
+5. **Generate unified metrics** for both storage types
+
+**Physical Drive Display:**
+```
+● nvme0n1:
+  ├─ ● Drive: T: 35°C W: 1%
+  ├─ ● Total: 23% 218.0GB/928.2GB
+  ├─ ● /boot: 11% 0.1GB/1.0GB
+  └─ ● /: 23% 214.9GB/928.2GB
+```
+
+**MergerFS Pool Display:**
+```
+● /srv/media (mergerfs):
+  ├─ ● Pool: 63% 2355.2GB/3686.4GB
+  ├─ Data Disks:
+  │  ├─ ● sdb T: 24°C
+  │  └─ ● sdd T: 27°C  
+  └─ ● sdc T: 24°C (parity)
+```
+
+**Implementation Benefits:**
+- **Pure auto-discovery**: No configuration needed
+- **Clean code paths**: Single workflow for all storage types
+- **Consistent display**: Status icons on every line, no redundant text
+- **Simple pipeline**: lsblk → df → group → metrics
+- **Support for both**: Physical drives and mergerfs pools
+
 ## Important Communication Guidelines
 
 Keep responses concise and focused. Avoid extensive implementation summaries unless requested.

Cargo.lock

@@ -279,7 +279,7 @@ checksum = "a1d728cc89cf3aee9ff92b05e62b19ee65a02b5702cff7d5a377e32c6ae29d8d"
 
 [[package]]
 name = "cm-dashboard"
-version = "0.1.96"
+version = "0.1.109"
 dependencies = [
  "anyhow",
  "chrono",
@@ -301,7 +301,7 @@ dependencies = [
 
 [[package]]
 name = "cm-dashboard-agent"
-version = "0.1.96"
+version = "0.1.109"
 dependencies = [
  "anyhow",
  "async-trait",
@@ -324,7 +324,7 @@ dependencies = [
 
 [[package]]
 name = "cm-dashboard-shared"
-version = "0.1.96"
+version = "0.1.109"
 dependencies = [
  "chrono",
  "serde",

agent/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "cm-dashboard-agent"
-version = "0.1.97"
+version = "0.1.110"
 edition = "2021"
 
 [dependencies]

agent/src/collectors/disk.rs

@@ -5,352 +5,156 @@ use cm_dashboard_shared::{Metric, MetricValue, Status, StatusTracker, Hysteresis
 use crate::config::DiskConfig;
 use std::process::Command;
 use std::time::Instant;
+use std::collections::HashMap;
 use tracing::debug;
 
 use super::{Collector, CollectorError};
 
-/// Information about a storage pool (mount point with underlying drives)
-#[derive(Debug, Clone)]
-struct StoragePool {
-    name: String,            // e.g., "steampool", "root"
-    mount_point: String,     // e.g., "/mnt/steampool", "/"
-    filesystem: String,      // e.g., "mergerfs", "ext4", "zfs", "btrfs"
-    storage_type: String,    // e.g., "mergerfs", "single", "raid", "zfs"
-    size: String,            // e.g., "2.5TB"
-    used: String,            // e.g., "2.1TB"
-    available: String,       // e.g., "400GB"
-    usage_percent: f32,      // e.g., 85.0
-    underlying_drives: Vec<DriveInfo>, // Individual physical drives
-}
-
-/// Information about an individual physical drive
-#[derive(Debug, Clone)]
-struct DriveInfo {
-    device: String,          // e.g., "sda", "nvme0n1"
-    health_status: String,   // e.g., "PASSED", "FAILED"
-    temperature: Option<f32>, // e.g., 45.0°C
-    wear_level: Option<f32>, // e.g., 12.0% (for SSDs)
-}
-
-/// Disk usage collector for monitoring filesystem sizes
+/// Storage collector with clean architecture
 pub struct DiskCollector {
     config: DiskConfig,
     temperature_thresholds: HysteresisThresholds,
-    detected_devices: std::collections::HashMap<String, Vec<String>>, // mount_point -> devices
+}
+
+/// A physical drive with its filesystems
+#[derive(Debug, Clone)]
+struct PhysicalDrive {
+    device: String,                    // e.g., "nvme0n1", "sda"
+    filesystems: Vec<Filesystem>,      // mounted filesystems on this drive
+    temperature: Option<f32>,          // drive temperature
+    wear_level: Option<f32>,          // SSD wear level
+    health_status: String,            // SMART health
+}
+
+/// A mergerfs pool
+#[derive(Debug, Clone)]
+struct MergerfsPool {
+    mount_point: String,              // e.g., "/srv/media"
+    total_bytes: u64,                // pool total capacity
+    used_bytes: u64,                 // pool used space
+    data_drives: Vec<DriveInfo>,     // data member drives
+    parity_drives: Vec<DriveInfo>,   // parity drives
+}
+
+/// Individual filesystem on a drive
+#[derive(Debug, Clone)]
+struct Filesystem {
+    mount_point: String,              // e.g., "/", "/boot"
+    total_bytes: u64,                // filesystem capacity
+    used_bytes: u64,                 // filesystem used space
+}
+
+/// Drive information for pools
+#[derive(Debug, Clone)]
+struct DriveInfo {
+    device: String,                   // e.g., "sdb", "sdc"
+    mount_point: String,             // e.g., "/mnt/disk1"
+    temperature: Option<f32>,        // drive temperature
+    wear_level: Option<f32>,         // SSD wear level  
+    health_status: String,           // SMART health
+}
+
+/// Discovered storage topology
+#[derive(Debug)]
+struct StorageTopology {
+    physical_drives: Vec<PhysicalDrive>,
+    mergerfs_pools: Vec<MergerfsPool>,
 }
 
 impl DiskCollector {
     pub fn new(config: DiskConfig) -> Self {
-        // Create hysteresis thresholds for disk temperature from config
         let temperature_thresholds = HysteresisThresholds::with_custom_gaps(
             config.temperature_warning_celsius,
-            5.0,  // 5°C gap for recovery
+            5.0,
             config.temperature_critical_celsius,
-            5.0,  // 5°C gap for recovery
+            5.0,
         );
         
-        // Detect devices for all configured filesystems at startup
-        let mut detected_devices = std::collections::HashMap::new();
-        for fs_config in &config.filesystems {
-            if fs_config.monitor {
-                if let Ok(devices) = Self::detect_device_for_mount_point_static(&fs_config.mount_point) {
-                    detected_devices.insert(fs_config.mount_point.clone(), devices);
-                }
-            }
-        }
-        
         Self { 
             config,
             temperature_thresholds,
-            detected_devices,
         }
     }
 
-    /// Calculate disk temperature status using hysteresis thresholds
-    fn calculate_temperature_status(&self, metric_name: &str, temperature: f32, status_tracker: &mut StatusTracker) -> Status {
-        status_tracker.calculate_with_hysteresis(metric_name, temperature, &self.temperature_thresholds)
-    }
-
-
-    /// Get configured storage pools with individual drive information
-    fn get_configured_storage_pools(&self) -> Result<Vec<StoragePool>> {
-        let mut storage_pools = Vec::new();
-
-        for fs_config in &self.config.filesystems {
-            if !fs_config.monitor {
-                continue;
-            }
-
-            // Get filesystem stats for the mount point
-            match self.get_filesystem_info(&fs_config.mount_point) {
-                Ok((total_bytes, used_bytes)) => {
-                    let available_bytes = total_bytes - used_bytes;
-                    let usage_percent = if total_bytes > 0 {
-                        (used_bytes as f64 / total_bytes as f64) * 100.0
-                    } else {
-                        0.0
-                    };
-
-                    // Convert bytes to human-readable format
-                    let size = self.bytes_to_human_readable(total_bytes);
-                    let used = self.bytes_to_human_readable(used_bytes);
-                    let available = self.bytes_to_human_readable(available_bytes);
-
-                    // Get individual drive information using pre-detected devices
-                    let device_names = self.detected_devices.get(&fs_config.mount_point).cloned().unwrap_or_default();
-                    let underlying_drives = self.get_drive_info_for_devices(&device_names)?;
-
-                    storage_pools.push(StoragePool {
-                        name: fs_config.name.clone(),
-                        mount_point: fs_config.mount_point.clone(),
-                        filesystem: fs_config.fs_type.clone(),
-                        storage_type: fs_config.storage_type.clone(),
-                        size,
-                        used,
-                        available,
-                        usage_percent: usage_percent as f32,
-                        underlying_drives,
-                    });
-
-                    debug!(
-                        "Storage pool '{}' ({}) at {} with {} detected drives",
-                        fs_config.name, fs_config.storage_type, fs_config.mount_point, device_names.len()
-                    );
-                }
-                Err(e) => {
-                    debug!(
-                        "Failed to get filesystem info for storage pool '{}': {}",
-                        fs_config.name, e
-                    );
-                }
-            }
-        }
-
-        Ok(storage_pools)
-    }
-
-    /// Get drive information for a list of device names
-    fn get_drive_info_for_devices(&self, device_names: &[String]) -> Result<Vec<DriveInfo>> {
-        let mut drives = Vec::new();
+    /// Discover all storage using clean workflow: lsblk → df → group
+    fn discover_storage(&self) -> Result<StorageTopology> {
+        debug!("Starting storage discovery");
         
-        for device_name in device_names {
-            let device_path = format!("/dev/{}", device_name);
-            
-            // Get SMART data for this drive
-            let (health_status, temperature, wear_level) = self.get_smart_data(&device_path);
-            
-            drives.push(DriveInfo {
-                device: device_name.clone(),
-                health_status: health_status.clone(),
-                temperature,
-                wear_level,
-            });
-            
-            debug!(
-                "Drive info for {}: health={}, temp={:?}°C, wear={:?}%",
-                device_name, health_status, temperature, wear_level
-            );
-        }
+        // Step 1: Get all mount points and their backing devices using lsblk
+        let mount_devices = self.get_mount_devices()?;
+        debug!("Found {} mount points", mount_devices.len());
         
-        Ok(drives)
+        // Step 2: Get filesystem usage for each mount point using df
+        let filesystem_usage = self.get_filesystem_usage(&mount_devices)?;
+        debug!("Got usage data for {} filesystems", filesystem_usage.len());
+        
+        // Step 3: Detect mergerfs pools from /proc/mounts
+        let mergerfs_pools = self.discover_mergerfs_pools()?;
+        debug!("Found {} mergerfs pools", mergerfs_pools.len());
+        
+        // Step 4: Group regular filesystems by physical drive
+        let physical_drives = self.group_by_physical_drive(&mount_devices, &filesystem_usage, &mergerfs_pools)?;
+        debug!("Grouped into {} physical drives", physical_drives.len());
+        
+        Ok(StorageTopology {
+            physical_drives,
+            mergerfs_pools,
+        })
     }
 
-    /// Get SMART data for a drive (health, temperature, wear level)
-    fn get_smart_data(&self, device_path: &str) -> (String, Option<f32>, Option<f32>) {
-        // Try to get SMART data using smartctl
-        let output = Command::new("sudo")
-            .arg("smartctl")
-            .arg("-a")
-            .arg(device_path)
-            .output();
-            
-        match output {
-            Ok(result) if result.status.success() => {
-                let stdout = String::from_utf8_lossy(&result.stdout);
-                
-                // Parse health status
-                let health = if stdout.contains("PASSED") {
-                    "PASSED".to_string()
-                } else if stdout.contains("FAILED") {
-                    "FAILED".to_string()
-                } else {
-                    "UNKNOWN".to_string()
-                };
-                
-                // Parse temperature (look for various temperature indicators)
-                let temperature = self.parse_temperature_from_smart(&stdout);
-                
-                // Parse wear level (for SSDs)
-                let wear_level = self.parse_wear_level_from_smart(&stdout);
-                
-                (health, temperature, wear_level)
-            }
-            _ => {
-                debug!("Failed to get SMART data for {}", device_path);
-                ("UNKNOWN".to_string(), None, None)
-            }
-        }
-    }
-
-    /// Parse temperature from SMART output
-    fn parse_temperature_from_smart(&self, smart_output: &str) -> Option<f32> {
-        for line in smart_output.lines() {
-            // Look for temperature in various formats
-            if line.contains("Temperature_Celsius") || line.contains("Temperature") {
-                let parts: Vec<&str> = line.split_whitespace().collect();
-                if parts.len() >= 10 {
-                    if let Ok(temp) = parts[9].parse::<f32>() {
-                        return Some(temp);
-                    }
-                }
-            }
-            // NVMe drives might show temperature differently
-            if line.contains("temperature:") {
-                if let Some(temp_part) = line.split("temperature:").nth(1) {
-                    if let Some(temp_str) = temp_part.split_whitespace().next() {
-                        if let Ok(temp) = temp_str.parse::<f32>() {
-                            return Some(temp);
-                        }
-                    }
-                }
-            }
-        }
-        None
-    }
-
-    /// Parse wear level from SMART output (SSD wear leveling)
-    /// Supports both NVMe and SATA SSD wear indicators
-    fn parse_wear_level_from_smart(&self, smart_output: &str) -> Option<f32> {
-        for line in smart_output.lines() {
-            let line = line.trim();
-            
-            // NVMe drives - direct percentage used
-            if line.contains("Percentage Used:") {
-                if let Some(wear_part) = line.split("Percentage Used:").nth(1) {
-                    if let Some(wear_str) = wear_part.split('%').next() {
-                        if let Ok(wear) = wear_str.trim().parse::<f32>() {
-                            return Some(wear);
-                        }
-                    }
-                }
-            }
-            
-            // SATA SSD attributes - parse SMART table format
-            // Format: ID ATTRIBUTE_NAME FLAG VALUE WORST THRESH TYPE UPDATED WHEN_FAILED RAW_VALUE
-            let parts: Vec<&str> = line.split_whitespace().collect();
-            if parts.len() >= 10 {
-                // SSD Life Left / Percent Lifetime Remaining (higher = less wear)
-                if line.contains("SSD_Life_Left") || line.contains("Percent_Lifetime_Remain") {
-                    if let Ok(remaining) = parts[3].parse::<f32>() { // VALUE column
-                        return Some(100.0 - remaining); // Convert remaining to used
-                    }
-                }
-                
-                // Media Wearout Indicator (lower = more wear, normalize to 0-100)
-                if line.contains("Media_Wearout_Indicator") {
-                    if let Ok(remaining) = parts[3].parse::<f32>() { // VALUE column
-                        return Some(100.0 - remaining); // Convert remaining to used
-                    }
-                }
-                
-                // Wear Leveling Count (higher = less wear, but varies by manufacturer)
-                if line.contains("Wear_Leveling_Count") {
-                    if let Ok(wear_count) = parts[3].parse::<f32>() { // VALUE column
-                        // Most SSDs: 100 = new, decreases with wear
-                        if wear_count <= 100.0 {
-                            return Some(100.0 - wear_count);
-                        }
-                    }
-                }
-                
-                // Total LBAs Written - calculate against typical endurance if available
-                // This is more complex and manufacturer-specific, so we skip for now
-            }
-        }
-        None
-    }
-
-    /// Convert bytes to human-readable format
-    fn bytes_to_human_readable(&self, bytes: u64) -> String {
-        const UNITS: &[&str] = &["B", "K", "M", "G", "T"];
-        let mut size = bytes as f64;
-        let mut unit_index = 0;
-
-        while size >= 1024.0 && unit_index < UNITS.len() - 1 {
-            size /= 1024.0;
-            unit_index += 1;
-        }
-
-        if unit_index == 0 {
-            format!("{:.0}{}", size, UNITS[unit_index])
-        } else {
-            format!("{:.1}{}", size, UNITS[unit_index])
-        }
-    }
-
-    /// Detect device backing a mount point using lsblk (static version for startup)
-    fn detect_device_for_mount_point_static(mount_point: &str) -> Result<Vec<String>> {
+    /// Use lsblk to get mount points and their backing devices
+    fn get_mount_devices(&self) -> Result<HashMap<String, String>> {
         let output = Command::new("lsblk")
             .args(&["-n", "-o", "NAME,MOUNTPOINT"])
             .output()?;
-        
+            
         if !output.status.success() {
-            return Ok(Vec::new());
+            return Err(anyhow::anyhow!("lsblk command failed"));
         }
         
+        let mut mount_devices = HashMap::new();
         let output_str = String::from_utf8_lossy(&output.stdout);
         
         for line in output_str.lines() {
             let parts: Vec<&str> = line.split_whitespace().collect();
-            if parts.len() >= 2 && parts[1] == mount_point {
-                // Remove tree symbols and extract device name (e.g., "├─nvme0n1p2" -> "nvme0n1p2")
+            if parts.len() >= 2 {
                 let device_name = parts[0]
                     .trim_start_matches('├')
                     .trim_start_matches('└')
                     .trim_start_matches('─')
                     .trim();
+                let mount_point = parts[1];
                 
-                // Extract base device name (e.g., "nvme0n1p2" -> "nvme0n1")
-                if let Some(base_device) = Self::extract_base_device(device_name) {
-                    return Ok(vec![base_device]);
+                // Skip unwanted mount points
+                if self.should_skip_mount_point(mount_point) {
+                    continue;
                 }
+                
+                mount_devices.insert(mount_point.to_string(), device_name.to_string());
             }
         }
         
-        Ok(Vec::new())
+        Ok(mount_devices)
     }
 
-    /// Extract base device name from partition (e.g., "nvme0n1p2" -> "nvme0n1", "sda1" -> "sda")
-    fn extract_base_device(device_name: &str) -> Option<String> {
-        // Handle NVMe devices (nvme0n1p1 -> nvme0n1)
-        if device_name.starts_with("nvme") {
-            if let Some(p_pos) = device_name.find('p') {
-                return Some(device_name[..p_pos].to_string());
-            }
-        }
-        
-        // Handle traditional devices (sda1 -> sda)
-        if device_name.len() > 1 {
-            let chars: Vec<char> = device_name.chars().collect();
-            let mut end_idx = chars.len();
-            
-            // Find where the device name ends and partition number begins
-            for (i, &c) in chars.iter().enumerate().rev() {
-                if !c.is_ascii_digit() {
-                    end_idx = i + 1;
-                    break;
-                }
-            }
-            
-            if end_idx > 0 && end_idx < chars.len() {
-                return Some(chars[..end_idx].iter().collect());
-            }
-        }
-        
-        // If no partition detected, return as-is
-        Some(device_name.to_string())
+    /// Check if we should skip this mount point
+    fn should_skip_mount_point(&self, mount_point: &str) -> bool {
+        let skip_prefixes = ["/proc", "/sys", "/dev", "/tmp", "/run"];
+        skip_prefixes.iter().any(|prefix| mount_point.starts_with(prefix))
     }
 
+    /// Use df to get filesystem usage for mount points
+    fn get_filesystem_usage(&self, mount_devices: &HashMap<String, String>) -> Result<HashMap<String, (u64, u64)>> {
+        let mut filesystem_usage = HashMap::new();
+        
+        for mount_point in mount_devices.keys() {
+            if let Ok((total, used)) = self.get_filesystem_info(mount_point) {
+                filesystem_usage.insert(mount_point.clone(), (total, used));
+            }
+        }
+        
+        Ok(filesystem_usage)
+    }
 
     /// Get filesystem info using df command
     fn get_filesystem_info(&self, path: &str) -> Result<(u64, u64)> {
@@ -381,216 +185,718 @@ impl DiskCollector {
         Ok((total_bytes, used_bytes))
     }
 
-
-    /// Parse size string (e.g., "120G", "45M") to GB value
-    fn parse_size_to_gb(&self, size_str: &str) -> f32 {
-        let size_str = size_str.trim();
-        if size_str.is_empty() || size_str == "-" {
-            return 0.0;
-        }
-
-        // Extract numeric part and unit
-        let (num_str, unit) = if let Some(last_char) = size_str.chars().last() {
-            if last_char.is_alphabetic() {
-                let num_part = &size_str[..size_str.len() - 1];
-                let unit_part = &size_str[size_str.len() - 1..];
-                (num_part, unit_part)
-            } else {
-                (size_str, "")
+    /// Discover mergerfs pools from /proc/mounts
+    fn discover_mergerfs_pools(&self) -> Result<Vec<MergerfsPool>> {
+        let mounts_content = std::fs::read_to_string("/proc/mounts")?;
+        let mut pools = Vec::new();
+        
+        for line in mounts_content.lines() {
+            let parts: Vec<&str> = line.split_whitespace().collect();
+            if parts.len() >= 3 && parts[2] == "fuse.mergerfs" {
+                let mount_point = parts[1].to_string();
+                let device_sources = parts[0]; // e.g., "/mnt/disk1:/mnt/disk2"
+                
+                // Get pool usage
+                let (total_bytes, used_bytes) = self.get_filesystem_info(&mount_point)
+                    .unwrap_or((0, 0));
+                
+                // Parse member paths
+                let member_paths: Vec<String> = device_sources
+                    .split(':')
+                    .map(|s| s.trim().to_string())
+                    .filter(|s| !s.is_empty())
+                    .collect();
+                
+                // Categorize as data vs parity drives
+                let (data_drives, parity_drives) = self.categorize_pool_drives(&member_paths)?;
+                
+                pools.push(MergerfsPool {
+                    mount_point,
+                    total_bytes,
+                    used_bytes,
+                    data_drives,
+                    parity_drives,
+                });
             }
-        } else {
-            (size_str, "")
-        };
-
-        let number: f32 = num_str.parse().unwrap_or(0.0);
-
-        match unit.to_uppercase().as_str() {
-            "T" | "TB" => number * 1024.0,
-            "G" | "GB" => number,
-            "M" | "MB" => number / 1024.0,
-            "K" | "KB" => number / (1024.0 * 1024.0),
-            "B" | "" => number / (1024.0 * 1024.0 * 1024.0),
-            _ => number, // Assume GB if unknown unit
         }
+        
+        Ok(pools)
+    }
+
+    /// Categorize pool member drives as data vs parity
+    fn categorize_pool_drives(&self, member_paths: &[String]) -> Result<(Vec<DriveInfo>, Vec<DriveInfo>)> {
+        let mut data_drives = Vec::new();
+        let mut parity_drives = Vec::new();
+        
+        for path in member_paths {
+            let drive_info = self.get_drive_info_for_path(path)?;
+            
+            // Heuristic: if path contains "parity", it's parity
+            if path.to_lowercase().contains("parity") {
+                parity_drives.push(drive_info);
+            } else {
+                data_drives.push(drive_info);
+            }
+        }
+        
+        Ok((data_drives, parity_drives))
+    }
+
+    /// Get drive information for a mount path
+    fn get_drive_info_for_path(&self, path: &str) -> Result<DriveInfo> {
+        // Use lsblk to find the backing device
+        let output = Command::new("lsblk")
+            .args(&["-n", "-o", "NAME,MOUNTPOINT"])
+            .output()?;
+            
+        let output_str = String::from_utf8_lossy(&output.stdout);
+        let mut device = String::new();
+        
+        for line in output_str.lines() {
+            let parts: Vec<&str> = line.split_whitespace().collect();
+            if parts.len() >= 2 && parts[1] == path {
+                device = parts[0]
+                    .trim_start_matches('├')
+                    .trim_start_matches('└')
+                    .trim_start_matches('─')
+                    .trim()
+                    .to_string();
+                break;
+            }
+        }
+        
+        if device.is_empty() {
+            return Err(anyhow::anyhow!("Could not find device for path {}", path));
+        }
+        
+        // Extract base device name (e.g., "sda1" -> "sda")
+        let base_device = self.extract_base_device(&device);
+        
+        // Get SMART data
+        let (health, temperature, wear) = self.get_smart_data(&format!("/dev/{}", base_device));
+        
+        Ok(DriveInfo {
+            device: base_device,
+            mount_point: path.to_string(),
+            temperature,
+            wear_level: wear,
+            health_status: health,
+        })
+    }
+
+    /// Extract base device name from partition (e.g., "nvme0n1p2" -> "nvme0n1", "sda1" -> "sda")
+    fn extract_base_device(&self, device_name: &str) -> String {
+        // Handle NVMe devices (nvme0n1p1 -> nvme0n1)
+        if device_name.starts_with("nvme") {
+            if let Some(p_pos) = device_name.find('p') {
+                return device_name[..p_pos].to_string();
+            }
+        }
+        
+        // Handle traditional devices (sda1 -> sda)
+        if device_name.len() > 1 {
+            let chars: Vec<char> = device_name.chars().collect();
+            let mut end_idx = chars.len();
+            
+            // Find where the device name ends and partition number begins
+            for (i, &c) in chars.iter().enumerate().rev() {
+                if !c.is_ascii_digit() {
+                    end_idx = i + 1;
+                    break;
+                }
+            }
+            
+            if end_idx > 0 && end_idx < chars.len() {
+                return chars[..end_idx].iter().collect();
+            }
+        }
+        
+        // If no partition detected, return as-is
+        device_name.to_string()
+    }
+
+    /// Group filesystems by physical drive (excluding mergerfs members)
+    fn group_by_physical_drive(
+        &self, 
+        mount_devices: &HashMap<String, String>,
+        filesystem_usage: &HashMap<String, (u64, u64)>,
+        mergerfs_pools: &[MergerfsPool]
+    ) -> Result<Vec<PhysicalDrive>> {
+        let mut drive_groups: HashMap<String, Vec<Filesystem>> = HashMap::new();
+        
+        // Get all mergerfs member paths to exclude them
+        let mut mergerfs_members = std::collections::HashSet::new();
+        for pool in mergerfs_pools {
+            for drive in &pool.data_drives {
+                mergerfs_members.insert(drive.mount_point.clone());
+            }
+            for drive in &pool.parity_drives {
+                mergerfs_members.insert(drive.mount_point.clone());
+            }
+        }
+        
+        // Group filesystems by base device
+        for (mount_point, device) in mount_devices {
+            // Skip mergerfs member mounts
+            if mergerfs_members.contains(mount_point) {
+                continue;
+            }
+            
+            let base_device = self.extract_base_device(device);
+            
+            if let Some((total, used)) = filesystem_usage.get(mount_point) {
+                let filesystem = Filesystem {
+                    mount_point: mount_point.clone(),
+                    total_bytes: *total,
+                    used_bytes: *used,
+                };
+                
+                drive_groups.entry(base_device).or_insert_with(Vec::new).push(filesystem);
+            }
+        }
+        
+        // Convert to PhysicalDrive structs with SMART data
+        let mut physical_drives = Vec::new();
+        for (device, filesystems) in drive_groups {
+            let (health, temperature, wear) = self.get_smart_data(&format!("/dev/{}", device));
+            
+            physical_drives.push(PhysicalDrive {
+                device,
+                filesystems,
+                temperature,
+                wear_level: wear,
+                health_status: health,
+            });
+        }
+        
+        Ok(physical_drives)
+    }
+
+    /// Get SMART data for a drive
+    fn get_smart_data(&self, device_path: &str) -> (String, Option<f32>, Option<f32>) {
+        let output = Command::new("sudo")
+            .arg("smartctl")
+            .arg("-a")
+            .arg(device_path)
+            .output();
+            
+        match output {
+            Ok(result) if result.status.success() => {
+                let stdout = String::from_utf8_lossy(&result.stdout);
+                
+                // Parse health status
+                let health = if stdout.contains("PASSED") {
+                    "PASSED".to_string()
+                } else if stdout.contains("FAILED") {
+                    "FAILED".to_string()
+                } else {
+                    "UNKNOWN".to_string()
+                };
+                
+                // Parse temperature and wear level
+                let temperature = self.parse_temperature_from_smart(&stdout);
+                let wear_level = self.parse_wear_level_from_smart(&stdout);
+                
+                (health, temperature, wear_level)
+            }
+            _ => {
+                debug!("Failed to get SMART data for {}", device_path);
+                ("UNKNOWN".to_string(), None, None)
+            }
+        }
+    }
+
+    /// Parse temperature from SMART output
+    fn parse_temperature_from_smart(&self, smart_output: &str) -> Option<f32> {
+        for line in smart_output.lines() {
+            if line.contains("Temperature_Celsius") || line.contains("Temperature") {
+                let parts: Vec<&str> = line.split_whitespace().collect();
+                if parts.len() >= 10 {
+                    if let Ok(temp) = parts[9].parse::<f32>() {
+                        return Some(temp);
+                    }
+                }
+            }
+            if line.contains("temperature:") {
+                if let Some(temp_part) = line.split("temperature:").nth(1) {
+                    if let Some(temp_str) = temp_part.split_whitespace().next() {
+                        if let Ok(temp) = temp_str.parse::<f32>() {
+                            return Some(temp);
+                        }
+                    }
+                }
+            }
+        }
+        None
+    }
+
+    /// Parse wear level from SMART output
+    fn parse_wear_level_from_smart(&self, smart_output: &str) -> Option<f32> {
+        for line in smart_output.lines() {
+            if line.contains("Percentage Used:") {
+                if let Some(wear_part) = line.split("Percentage Used:").nth(1) {
+                    if let Some(wear_str) = wear_part.split('%').next() {
+                        if let Ok(wear) = wear_str.trim().parse::<f32>() {
+                            return Some(wear);
+                        }
+                    }
+                }
+            }
+            
+            let parts: Vec<&str> = line.split_whitespace().collect();
+            if parts.len() >= 10 {
+                if line.contains("SSD_Life_Left") || line.contains("Percent_Lifetime_Remain") {
+                    if let Ok(remaining) = parts[3].parse::<f32>() {
+                        return Some(100.0 - remaining);
+                    }
+                }
+                if line.contains("Wear_Leveling_Count") {
+                    if let Ok(wear_count) = parts[3].parse::<f32>() {
+                        if wear_count <= 100.0 {
+                            return Some(100.0 - wear_count);
+                        }
+                    }
+                }
+            }
+        }
+        None
+    }
+
+    /// Calculate temperature status with hysteresis
+    fn calculate_temperature_status(&self, metric_name: &str, temperature: f32, status_tracker: &mut StatusTracker) -> Status {
+        status_tracker.calculate_with_hysteresis(metric_name, temperature, &self.temperature_thresholds)
+    }
+
+    /// Convert bytes to human readable format
+    fn bytes_to_human_readable(&self, bytes: u64) -> String {
+        const UNITS: &[&str] = &["B", "K", "M", "G", "T"];
+        let mut size = bytes as f64;
+        let mut unit_index = 0;
+
+        while size >= 1024.0 && unit_index < UNITS.len() - 1 {
+            size /= 1024.0;
+            unit_index += 1;
+        }
+
+        if unit_index == 0 {
+            format!("{:.0}{}", size, UNITS[unit_index])
+        } else {
+            format!("{:.1}{}", size, UNITS[unit_index])
+        }
+    }
+
+    /// Convert bytes to gigabytes
+    fn bytes_to_gb(&self, bytes: u64) -> f32 {
+        bytes as f32 / (1024.0 * 1024.0 * 1024.0)
     }
 }
 
 #[async_trait]
 impl Collector for DiskCollector {
-
     async fn collect(&self, status_tracker: &mut StatusTracker) -> Result<Vec<Metric>, CollectorError> {
         let start_time = Instant::now();
-        debug!("Collecting storage pool and individual drive metrics");
+        debug!("Starting clean storage collection");
 
         let mut metrics = Vec::new();
+        let timestamp = chrono::Utc::now().timestamp() as u64;
 
-        // Get configured storage pools with individual drive data
-        let storage_pools = match self.get_configured_storage_pools() {
-            Ok(pools) => {
-                debug!("Found {} storage pools", pools.len());
-                pools
-            }
+        // Discover storage topology
+        let topology = match self.discover_storage() {
+            Ok(topology) => topology,
             Err(e) => {
-                debug!("Failed to get storage pools: {}", e);
-                Vec::new()
+                debug!("Storage discovery failed: {}", e);
+                return Ok(metrics);
             }
         };
 
-        // Generate metrics for each storage pool and its underlying drives
-        for storage_pool in &storage_pools {
-            let timestamp = chrono::Utc::now().timestamp() as u64;
+        // Generate metrics for physical drives
+        for drive in &topology.physical_drives {
+            self.generate_physical_drive_metrics(&mut metrics, drive, timestamp, status_tracker);
+        }
 
-            // Storage pool overall metrics
-            let pool_name = &storage_pool.name;
-            
-            // Parse size strings to get actual values for calculations
-            let size_gb = self.parse_size_to_gb(&storage_pool.size);
-            let used_gb = self.parse_size_to_gb(&storage_pool.used);
-            let avail_gb = self.parse_size_to_gb(&storage_pool.available);
+        // Generate metrics for mergerfs pools
+        for pool in &topology.mergerfs_pools {
+            self.generate_mergerfs_pool_metrics(&mut metrics, pool, timestamp, status_tracker);
+        }
 
-            // Calculate status based on configured thresholds
-            let pool_status = if storage_pool.usage_percent >= self.config.usage_critical_percent {
+        // Add total storage count
+        let total_storage = topology.physical_drives.len() + topology.mergerfs_pools.len();
+        metrics.push(Metric {
+            name: "disk_count".to_string(),
+            value: MetricValue::Integer(total_storage as i64),
+            unit: None,
+            description: Some(format!("Total storage: {} drives, {} pools", topology.physical_drives.len(), topology.mergerfs_pools.len())),
+            status: Status::Ok,
+            timestamp,
+        });
+
+        let collection_time = start_time.elapsed();
+        debug!("Clean storage collection completed in {:?} with {} metrics", collection_time, metrics.len());
+
+        Ok(metrics)
+    }
+}
+
+impl DiskCollector {
+    /// Generate metrics for a physical drive and its filesystems
+    fn generate_physical_drive_metrics(
+        &self,
+        metrics: &mut Vec<Metric>,
+        drive: &PhysicalDrive,
+        timestamp: u64,
+        status_tracker: &mut StatusTracker
+    ) {
+        let drive_name = &drive.device;
+        
+        // Calculate drive totals
+        let total_capacity: u64 = drive.filesystems.iter().map(|fs| fs.total_bytes).sum();
+        let total_used: u64 = drive.filesystems.iter().map(|fs| fs.used_bytes).sum();
+        let total_available = total_capacity.saturating_sub(total_used);
+        let usage_percent = if total_capacity > 0 {
+            (total_used as f64 / total_capacity as f64) * 100.0
+        } else { 0.0 };
+        
+        // Drive health status
+        let health_status = if drive.health_status == "PASSED" { Status::Ok } 
+                           else if drive.health_status == "FAILED" { Status::Critical }
+                           else { Status::Unknown };
+        
+        // Usage status
+        let usage_status = if usage_percent >= self.config.usage_critical_percent as f64 {
+            Status::Critical
+        } else if usage_percent >= self.config.usage_warning_percent as f64 {
+            Status::Warning
+        } else {
+            Status::Ok
+        };
+        
+        let drive_status = if health_status == Status::Critical { Status::Critical } else { usage_status };
+
+        // Drive info metrics
+        metrics.push(Metric {
+            name: format!("disk_{}_health", drive_name),
+            value: MetricValue::String(drive.health_status.clone()),
+            unit: None,
+            description: Some(format!("{}: {}", drive_name, drive.health_status)),
+            status: health_status,
+            timestamp,
+        });
+
+        // Drive temperature
+        if let Some(temp) = drive.temperature {
+            let temp_status = self.calculate_temperature_status(
+                &format!("disk_{}_temperature", drive_name), temp, status_tracker
+            );
+            metrics.push(Metric {
+                name: format!("disk_{}_temperature", drive_name),
+                value: MetricValue::Float(temp),
+                unit: Some("°C".to_string()),
+                description: Some(format!("{}: {:.0}°C", drive_name, temp)),
+                status: temp_status,
+                timestamp,
+            });
+        }
+
+        // Drive wear level
+        if let Some(wear) = drive.wear_level {
+            let wear_status = if wear >= self.config.wear_critical_percent { Status::Critical }
+                             else if wear >= self.config.wear_warning_percent { Status::Warning }
+                             else { Status::Ok };
+            metrics.push(Metric {
+                name: format!("disk_{}_wear_percent", drive_name),
+                value: MetricValue::Float(wear),
+                unit: Some("%".to_string()),
+                description: Some(format!("{}: {:.0}% wear", drive_name, wear)),
+                status: wear_status,
+                timestamp,
+            });
+        }
+
+        // Drive capacity metrics
+        metrics.push(Metric {
+            name: format!("disk_{}_total_gb", drive_name),
+            value: MetricValue::Float(self.bytes_to_gb(total_capacity)),
+            unit: Some("GB".to_string()),
+            description: Some(format!("{}: {}", drive_name, self.bytes_to_human_readable(total_capacity))),
+            status: Status::Ok,
+            timestamp,
+        });
+
+        metrics.push(Metric {
+            name: format!("disk_{}_used_gb", drive_name),
+            value: MetricValue::Float(self.bytes_to_gb(total_used)),
+            unit: Some("GB".to_string()),
+            description: Some(format!("{}: {}", drive_name, self.bytes_to_human_readable(total_used))),
+            status: drive_status.clone(),
+            timestamp,
+        });
+
+        metrics.push(Metric {
+            name: format!("disk_{}_available_gb", drive_name),
+            value: MetricValue::Float(self.bytes_to_gb(total_available)),
+            unit: Some("GB".to_string()),
+            description: Some(format!("{}: {}", drive_name, self.bytes_to_human_readable(total_available))),
+            status: Status::Ok,
+            timestamp,
+        });
+
+        metrics.push(Metric {
+            name: format!("disk_{}_usage_percent", drive_name),
+            value: MetricValue::Float(usage_percent as f32),
+            unit: Some("%".to_string()),
+            description: Some(format!("{}: {:.1}%", drive_name, usage_percent)),
+            status: drive_status,
+            timestamp,
+        });
+
+        // Pool type indicator
+        metrics.push(Metric {
+            name: format!("disk_{}_pool_type", drive_name),
+            value: MetricValue::String(format!("drive ({})", drive.filesystems.len())),
+            unit: None,
+            description: Some(format!("Type: physical drive")),
+            status: Status::Ok,
+            timestamp,
+        });
+
+        // Individual filesystem metrics
+        for filesystem in &drive.filesystems {
+            let fs_name = if filesystem.mount_point == "/" {
+                "root".to_string()
+            } else {
+                filesystem.mount_point.trim_start_matches('/').replace('/', "_")
+            };
+
+            let fs_usage_percent = if filesystem.total_bytes > 0 {
+                (filesystem.used_bytes as f64 / filesystem.total_bytes as f64) * 100.0
+            } else { 0.0 };
+
+            let fs_status = if fs_usage_percent >= self.config.usage_critical_percent as f64 {
                 Status::Critical
-            } else if storage_pool.usage_percent >= self.config.usage_warning_percent {
+            } else if fs_usage_percent >= self.config.usage_warning_percent as f64 {
                 Status::Warning
             } else {
                 Status::Ok
             };
 
-            // Storage pool info metrics
             metrics.push(Metric {
-                name: format!("disk_{}_mount_point", pool_name),
-                value: MetricValue::String(storage_pool.mount_point.clone()),
-                unit: None,
-                description: Some(format!("Mount: {}", storage_pool.mount_point)),
-                status: Status::Ok,
-                timestamp,
-            });
-
-            metrics.push(Metric {
-                name: format!("disk_{}_filesystem", pool_name),
-                value: MetricValue::String(storage_pool.filesystem.clone()),
-                unit: None,
-                description: Some(format!("FS: {}", storage_pool.filesystem)),
-                status: Status::Ok,
-                timestamp,
-            });
-
-            metrics.push(Metric {
-                name: format!("disk_{}_storage_type", pool_name),
-                value: MetricValue::String(storage_pool.storage_type.clone()),
-                unit: None,
-                description: Some(format!("Type: {}", storage_pool.storage_type)),
-                status: Status::Ok,
-                timestamp,
-            });
-
-            // Storage pool size metrics
-            metrics.push(Metric {
-                name: format!("disk_{}_total_gb", pool_name),
-                value: MetricValue::Float(size_gb),
-                unit: Some("GB".to_string()),
-                description: Some(format!("Total: {}", storage_pool.size)),
-                status: Status::Ok,
-                timestamp,
-            });
-
-            metrics.push(Metric {
-                name: format!("disk_{}_used_gb", pool_name),
-                value: MetricValue::Float(used_gb),
-                unit: Some("GB".to_string()),
-                description: Some(format!("Used: {}", storage_pool.used)),
-                status: pool_status,
-                timestamp,
-            });
-
-            metrics.push(Metric {
-                name: format!("disk_{}_available_gb", pool_name),
-                value: MetricValue::Float(avail_gb),
-                unit: Some("GB".to_string()),
-                description: Some(format!("Available: {}", storage_pool.available)),
-                status: Status::Ok,
-                timestamp,
-            });
-
-            metrics.push(Metric {
-                name: format!("disk_{}_usage_percent", pool_name),
-                value: MetricValue::Float(storage_pool.usage_percent),
+                name: format!("disk_{}_fs_{}_usage_percent", drive_name, fs_name),
+                value: MetricValue::Float(fs_usage_percent as f32),
                 unit: Some("%".to_string()),
-                description: Some(format!("Usage: {:.1}%", storage_pool.usage_percent)),
-                status: pool_status,
+                description: Some(format!("{}: {:.0}%", filesystem.mount_point, fs_usage_percent)),
+                status: fs_status.clone(),
                 timestamp,
             });
 
-            // Individual drive metrics for this storage pool
-            for drive in &storage_pool.underlying_drives {
-                // Drive health status
-                metrics.push(Metric {
-                    name: format!("disk_{}_{}_health", pool_name, drive.device),
-                    value: MetricValue::String(drive.health_status.clone()),
-                    unit: None,
-                    description: Some(format!("{}: {}", drive.device, drive.health_status)),
-                    status: if drive.health_status == "PASSED" { Status::Ok } 
-                            else if drive.health_status == "FAILED" { Status::Critical }
-                            else { Status::Unknown },
-                    timestamp,
-                });
+            metrics.push(Metric {
+                name: format!("disk_{}_fs_{}_used_gb", drive_name, fs_name),
+                value: MetricValue::Float(self.bytes_to_gb(filesystem.used_bytes)),
+                unit: Some("GB".to_string()),
+                description: Some(format!("{}: {}", filesystem.mount_point, self.bytes_to_human_readable(filesystem.used_bytes))),
+                status: Status::Ok,
+                timestamp,
+            });
 
-                // Drive temperature
-                if let Some(temp) = drive.temperature {
-                    let temp_status = self.calculate_temperature_status(
-                        &format!("disk_{}_{}_temperature", pool_name, drive.device),
-                        temp,
-                        status_tracker
-                    );
-                    
-                    metrics.push(Metric {
-                        name: format!("disk_{}_{}_temperature", pool_name, drive.device),
-                        value: MetricValue::Float(temp),
-                        unit: Some("°C".to_string()),
-                        description: Some(format!("{}: {:.0}°C", drive.device, temp)),
-                        status: temp_status,
-                        timestamp,
-                    });
-                }
+            metrics.push(Metric {
+                name: format!("disk_{}_fs_{}_total_gb", drive_name, fs_name),
+                value: MetricValue::Float(self.bytes_to_gb(filesystem.total_bytes)),
+                unit: Some("GB".to_string()),
+                description: Some(format!("{}: {}", filesystem.mount_point, self.bytes_to_human_readable(filesystem.total_bytes))),
+                status: Status::Ok,
+                timestamp,
+            });
 
-                // Drive wear level (for SSDs)
-                if let Some(wear) = drive.wear_level {
-                    let wear_status = if wear >= self.config.wear_critical_percent { Status::Critical }
-                                     else if wear >= self.config.wear_warning_percent { Status::Warning }
-                                     else { Status::Ok };
-                    
-                    metrics.push(Metric {
-                        name: format!("disk_{}_{}_wear_percent", pool_name, drive.device),
-                        value: MetricValue::Float(wear),
-                        unit: Some("%".to_string()),
-                        description: Some(format!("{}: {:.0}% wear", drive.device, wear)),
-                        status: wear_status,
-                        timestamp,
-                    });
-                }
-            }
+            let fs_available = filesystem.total_bytes.saturating_sub(filesystem.used_bytes);
+            metrics.push(Metric {
+                name: format!("disk_{}_fs_{}_available_gb", drive_name, fs_name),
+                value: MetricValue::Float(self.bytes_to_gb(fs_available)),
+                unit: Some("GB".to_string()),
+                description: Some(format!("{}: {}", filesystem.mount_point, self.bytes_to_human_readable(fs_available))),
+                status: Status::Ok,
+                timestamp,
+            });
+
+            metrics.push(Metric {
+                name: format!("disk_{}_fs_{}_mount_point", drive_name, fs_name),
+                value: MetricValue::String(filesystem.mount_point.clone()),
+                unit: None,
+                description: Some(format!("Mount: {}", filesystem.mount_point)),
+                status: Status::Ok,
+                timestamp,
+            });
         }
-
-        // Add storage pool count metric
-        metrics.push(Metric {
-            name: "disk_count".to_string(),
-            value: MetricValue::Integer(storage_pools.len() as i64),
-            unit: None,
-            description: Some(format!("Total storage pools: {}", storage_pools.len())),
-            status: Status::Ok,
-            timestamp: chrono::Utc::now().timestamp() as u64,
-        });
-
-
-        let collection_time = start_time.elapsed();
-        debug!(
-            "Multi-disk collection completed in {:?} with {} metrics",
-            collection_time,
-            metrics.len()
-        );
-
-        Ok(metrics)
     }
 
-}
+    /// Generate metrics for a mergerfs pool
+    fn generate_mergerfs_pool_metrics(
+        &self,
+        metrics: &mut Vec<Metric>,
+        pool: &MergerfsPool,
+        timestamp: u64,
+        status_tracker: &mut StatusTracker
+    ) {
+        let pool_name = pool.mount_point.trim_start_matches('/').replace('/', "_");
+        if pool_name.is_empty() {
+            return;
+        }
+
+        let usage_percent = if pool.total_bytes > 0 {
+            (pool.used_bytes as f64 / pool.total_bytes as f64) * 100.0
+        } else { 0.0 };
+
+        // Calculate pool health based on drive health
+        let failed_data = pool.data_drives.iter()
+            .filter(|d| d.health_status != "PASSED")
+            .count();
+        let failed_parity = pool.parity_drives.iter()
+            .filter(|d| d.health_status != "PASSED")
+            .count();
+
+        let pool_health = match (failed_data, failed_parity) {
+            (0, 0) => Status::Ok,
+            (1, 0) | (0, 1) => Status::Warning,
+            _ => Status::Critical,
+        };
+
+        let usage_status = if usage_percent >= self.config.usage_critical_percent as f64 {
+            Status::Critical
+        } else if usage_percent >= self.config.usage_warning_percent as f64 {
+            Status::Warning
+        } else {
+            Status::Ok
+        };
+
+        let pool_status = if pool_health == Status::Critical { Status::Critical } else { usage_status };
+
+        // Pool metrics
+        metrics.push(Metric {
+            name: format!("disk_{}_mount_point", pool_name),
+            value: MetricValue::String(pool.mount_point.clone()),
+            unit: None,
+            description: Some(format!("Mount: {}", pool.mount_point)),
+            status: Status::Ok,
+            timestamp,
+        });
+
+        metrics.push(Metric {
+            name: format!("disk_{}_pool_type", pool_name),
+            value: MetricValue::String(format!("mergerfs ({}+{})", pool.data_drives.len(), pool.parity_drives.len())),
+            unit: None,
+            description: Some("Type: mergerfs".to_string()),
+            status: Status::Ok,
+            timestamp,
+        });
+
+        metrics.push(Metric {
+            name: format!("disk_{}_pool_health", pool_name),
+            value: MetricValue::String(match pool_health {
+                Status::Ok => "healthy".to_string(),
+                Status::Warning => "degraded".to_string(),
+                Status::Critical => "critical".to_string(),
+                _ => "unknown".to_string(),
+            }),
+            unit: None,
+            description: Some("Pool health".to_string()),
+            status: pool_health,
+            timestamp,
+        });
+
+        metrics.push(Metric {
+            name: format!("disk_{}_total_gb", pool_name),
+            value: MetricValue::Float(self.bytes_to_gb(pool.total_bytes)),
+            unit: Some("GB".to_string()),
+            description: Some(format!("Total: {}", self.bytes_to_human_readable(pool.total_bytes))),
+            status: Status::Ok,
+            timestamp,
+        });
+
+        metrics.push(Metric {
+            name: format!("disk_{}_used_gb", pool_name),
+            value: MetricValue::Float(self.bytes_to_gb(pool.used_bytes)),
+            unit: Some("GB".to_string()),
+            description: Some(format!("Used: {}", self.bytes_to_human_readable(pool.used_bytes))),
+            status: pool_status.clone(),
+            timestamp,
+        });
+
+        let available_bytes = pool.total_bytes.saturating_sub(pool.used_bytes);
+        metrics.push(Metric {
+            name: format!("disk_{}_available_gb", pool_name),
+            value: MetricValue::Float(self.bytes_to_gb(available_bytes)),
+            unit: Some("GB".to_string()),
+            description: Some(format!("Available: {}", self.bytes_to_human_readable(available_bytes))),
+            status: Status::Ok,
+            timestamp,
+        });
+
+        metrics.push(Metric {
+            name: format!("disk_{}_usage_percent", pool_name),
+            value: MetricValue::Float(usage_percent as f32),
+            unit: Some("%".to_string()),
+            description: Some(format!("Usage: {:.1}%", usage_percent)),
+            status: pool_status,
+            timestamp,
+        });
+
+        // Individual drive metrics
+        for (i, drive) in pool.data_drives.iter().enumerate() {
+            self.generate_pool_drive_metrics(metrics, &pool_name, &format!("data_{}", i), drive, timestamp, status_tracker);
+        }
+
+        for (i, drive) in pool.parity_drives.iter().enumerate() {
+            self.generate_pool_drive_metrics(metrics, &pool_name, &format!("parity_{}", i), drive, timestamp, status_tracker);
+        }
+    }
+
+    /// Generate metrics for drives in mergerfs pools
+    fn generate_pool_drive_metrics(
+        &self,
+        metrics: &mut Vec<Metric>,
+        pool_name: &str,
+        drive_role: &str,
+        drive: &DriveInfo,
+        timestamp: u64,
+        status_tracker: &mut StatusTracker
+    ) {
+        let drive_health = if drive.health_status == "PASSED" { Status::Ok }
+                          else if drive.health_status == "FAILED" { Status::Critical }
+                          else { Status::Unknown };
+
+        metrics.push(Metric {
+            name: format!("disk_{}_{}_health", pool_name, drive_role),
+            value: MetricValue::String(drive.health_status.clone()),
+            unit: None,
+            description: Some(format!("{}: {}", drive.device, drive.health_status)),
+            status: drive_health,
+            timestamp,
+        });
+
+        if let Some(temp) = drive.temperature {
+            let temp_status = self.calculate_temperature_status(
+                &format!("disk_{}_{}_temperature", pool_name, drive_role), temp, status_tracker
+            );
+            metrics.push(Metric {
+                name: format!("disk_{}_{}_temperature", pool_name, drive_role),
+                value: MetricValue::Float(temp),
+                unit: Some("°C".to_string()),
+                description: Some(format!("{}: {:.0}°C", drive.device, temp)),
+                status: temp_status,
+                timestamp,
+            });
+        }
+
+        if let Some(wear) = drive.wear_level {
+            let wear_status = if wear >= self.config.wear_critical_percent { Status::Critical }
+                             else if wear >= self.config.wear_warning_percent { Status::Warning }
+                             else { Status::Ok };
+            metrics.push(Metric {
+                name: format!("disk_{}_{}_wear_percent", pool_name, drive_role),
+                value: MetricValue::Float(wear),
+                unit: Some("%".to_string()),
+                description: Some(format!("{}: {:.0}% wear", drive.device, wear)),
+                status: wear_status,
+                timestamp,
+            });
+        }
+    }
+}

agent/src/collectors/disk_old.rs

@@ -0,0 +1,1327 @@
+use anyhow::Result;
+use async_trait::async_trait;
+use cm_dashboard_shared::{Metric, MetricValue, Status, StatusTracker, HysteresisThresholds};
+
+use crate::config::DiskConfig;
+use std::process::Command;
+use std::time::Instant;
+use std::fs;
+use tracing::debug;
+
+use super::{Collector, CollectorError};
+
+/// Mount point information from /proc/mounts
+#[derive(Debug, Clone)]
+struct MountInfo {
+    device: String,      // e.g., "/dev/sda1" or "/mnt/disk1:/mnt/disk2"
+    mount_point: String, // e.g., "/", "/srv/media"
+    fs_type: String,     // e.g., "ext4", "xfs", "fuse.mergerfs"
+}
+
+/// Auto-discovered storage topology
+#[derive(Debug, Clone)]
+struct StorageTopology {
+    single_disks: Vec<MountInfo>,
+    mergerfs_pools: Vec<MergerfsPoolInfo>,
+}
+
+/// MergerFS pool information
+#[derive(Debug, Clone)]
+struct MergerfsPoolInfo {
+    mount_point: String,          // e.g., "/srv/media"
+    data_members: Vec<String>,    // e.g., ["/mnt/disk1", "/mnt/disk2"]
+    parity_disks: Vec<String>,    // e.g., ["/mnt/parity"]
+}
+
+/// Information about a storage pool (mount point with underlying drives)
+#[derive(Debug, Clone)]
+struct StoragePool {
+    name: String,            // e.g., "steampool", "root"
+    mount_point: String,     // e.g., "/mnt/steampool", "/"
+    filesystem: String,      // e.g., "mergerfs", "ext4", "zfs", "btrfs"
+    pool_type: StoragePoolType, // Enhanced pool type with configuration
+    size: String,            // e.g., "2.5TB"
+    used: String,            // e.g., "2.1TB"
+    available: String,       // e.g., "400GB"
+    usage_percent: f32,      // e.g., 85.0
+    underlying_drives: Vec<DriveInfo>, // Individual physical drives
+    pool_health: PoolHealth, // Overall pool health status
+}
+
+/// Enhanced storage pool types with specific configurations
+#[derive(Debug, Clone)]
+enum StoragePoolType {
+    Single,                    // Traditional single disk (legacy)
+    PhysicalDrive {           // Physical drive with multiple filesystems
+        filesystems: Vec<String>,     // Mount points on this drive
+    },
+    MergerfsPool {            // MergerFS with optional parity
+        data_disks: Vec<String>,      // Member disk names (sdb, sdd)
+        parity_disks: Vec<String>,    // Parity disk names (sdc)
+    },
+    #[allow(dead_code)]
+    RaidArray {               // Hardware RAID (future)
+        level: String,               // "RAID1", "RAID5", etc.
+        member_disks: Vec<String>,   
+        spare_disks: Vec<String>,
+    },
+    #[allow(dead_code)]
+    ZfsPool {                 // ZFS pool (future)
+        pool_name: String,
+        vdevs: Vec<String>,
+    }
+}
+
+/// Pool health status for redundant storage
+#[derive(Debug, Clone, Copy, PartialEq)]
+enum PoolHealth {
+    Healthy,           // All drives OK, parity current
+    Degraded,          // One drive failed or parity outdated, still functional
+    Critical,          // Multiple failures, data at risk
+    #[allow(dead_code)]
+    Rebuilding,        // Actively rebuilding/scrubbing (future: SnapRAID status integration)
+    Unknown,           // Cannot determine status
+}
+
+/// Information about an individual physical drive
+#[derive(Debug, Clone)]
+struct DriveInfo {
+    device: String,          // e.g., "sda", "nvme0n1"
+    health_status: String,   // e.g., "PASSED", "FAILED"
+    temperature: Option<f32>, // e.g., 45.0°C
+    wear_level: Option<f32>, // e.g., 12.0% (for SSDs)
+}
+
+/// Disk usage collector for monitoring filesystem sizes
+pub struct DiskCollector {
+    config: DiskConfig,
+    temperature_thresholds: HysteresisThresholds,
+    detected_devices: std::collections::HashMap<String, Vec<String>>, // mount_point -> devices
+    storage_topology: Option<StorageTopology>, // Auto-discovered storage layout
+}
+
+impl DiskCollector {
+    pub fn new(config: DiskConfig) -> Self {
+        // Create hysteresis thresholds for disk temperature from config
+        let temperature_thresholds = HysteresisThresholds::with_custom_gaps(
+            config.temperature_warning_celsius,
+            5.0,  // 5°C gap for recovery
+            config.temperature_critical_celsius,
+            5.0,  // 5°C gap for recovery
+        );
+        
+        // Perform auto-discovery of storage topology
+        let storage_topology = match Self::auto_discover_storage() {
+            Ok(topology) => {
+                debug!("Auto-discovered storage topology: {} single disks, {} mergerfs pools", 
+                       topology.single_disks.len(), topology.mergerfs_pools.len());
+                Some(topology)
+            }
+            Err(e) => {
+                debug!("Failed to auto-discover storage topology: {}", e);
+                None
+            }
+        };
+        
+        // Detect devices for discovered storage
+        let mut detected_devices = std::collections::HashMap::new();
+        if let Some(ref topology) = storage_topology {
+            // Add single disks
+            for disk in &topology.single_disks {
+                if let Ok(devices) = Self::detect_device_for_mount_point_static(&disk.mount_point) {
+                    detected_devices.insert(disk.mount_point.clone(), devices);
+                }
+            }
+            
+            // Add mergerfs pools and their members
+            for pool in &topology.mergerfs_pools {
+                // Detect devices for the pool itself
+                if let Ok(devices) = Self::detect_device_for_mount_point_static(&pool.mount_point) {
+                    detected_devices.insert(pool.mount_point.clone(), devices);
+                }
+                
+                // Detect devices for member disks
+                for member in &pool.data_members {
+                    if let Ok(devices) = Self::detect_device_for_mount_point_static(member) {
+                        detected_devices.insert(member.clone(), devices);
+                    }
+                }
+                
+                // Detect devices for parity disks
+                for parity in &pool.parity_disks {
+                    if let Ok(devices) = Self::detect_device_for_mount_point_static(parity) {
+                        detected_devices.insert(parity.clone(), devices);
+                    }
+                }
+            }
+        } else {
+            // Fallback: use legacy filesystem config detection
+            for fs_config in &config.filesystems {
+                if fs_config.monitor {
+                    if let Ok(devices) = Self::detect_device_for_mount_point_static(&fs_config.mount_point) {
+                        detected_devices.insert(fs_config.mount_point.clone(), devices);
+                    }
+                }
+            }
+        }
+        
+        Self { 
+            config,
+            temperature_thresholds,
+            detected_devices,
+            storage_topology,
+        }
+    }
+
+    /// Auto-discover storage topology by parsing system information
+    fn auto_discover_storage() -> Result<StorageTopology> {
+        let mounts = Self::parse_proc_mounts()?;
+        let mut single_disks = Vec::new();
+        let mut mergerfs_pools = Vec::new();
+        
+        // Filter out unwanted filesystem types and mount points
+        let exclude_fs_types = ["tmpfs", "devtmpfs", "sysfs", "proc", "cgroup", "cgroup2", "devpts"];
+        let exclude_mount_prefixes = ["/proc", "/sys", "/dev", "/tmp", "/run"];
+        
+        for mount in mounts {
+            // Skip excluded filesystem types
+            if exclude_fs_types.contains(&mount.fs_type.as_str()) {
+                continue;
+            }
+            
+            // Skip excluded mount point prefixes
+            if exclude_mount_prefixes.iter().any(|prefix| mount.mount_point.starts_with(prefix)) {
+                continue;
+            }
+            
+            match mount.fs_type.as_str() {
+                "fuse.mergerfs" => {
+                    // Parse mergerfs pool
+                    let data_members = Self::parse_mergerfs_sources(&mount.device);
+                    let parity_disks = Self::detect_parity_disks(&data_members);
+                    
+                    mergerfs_pools.push(MergerfsPoolInfo {
+                        mount_point: mount.mount_point.clone(),
+                        data_members,
+                        parity_disks,
+                    });
+                    
+                    debug!("Discovered mergerfs pool at {}", mount.mount_point);
+                }
+                "ext4" | "xfs" | "btrfs" | "ntfs" | "vfat" => {
+                    // Check if this mount is part of a mergerfs pool
+                    let is_mergerfs_member = mergerfs_pools.iter()
+                        .any(|pool| pool.data_members.contains(&mount.mount_point) || 
+                                   pool.parity_disks.contains(&mount.mount_point));
+                    
+                    if !is_mergerfs_member {
+                        debug!("Discovered single disk at {}", mount.mount_point);
+                        single_disks.push(mount);
+                    }
+                }
+                _ => {
+                    debug!("Skipping unsupported filesystem type: {}", mount.fs_type);
+                }
+            }
+        }
+        
+        Ok(StorageTopology {
+            single_disks,
+            mergerfs_pools,
+        })
+    }
+
+    /// Parse /proc/mounts to get all mount information
+    fn parse_proc_mounts() -> Result<Vec<MountInfo>> {
+        let mounts_content = fs::read_to_string("/proc/mounts")?;
+        let mut mounts = Vec::new();
+        
+        for line in mounts_content.lines() {
+            let parts: Vec<&str> = line.split_whitespace().collect();
+            if parts.len() >= 3 {
+                mounts.push(MountInfo {
+                    device: parts[0].to_string(),
+                    mount_point: parts[1].to_string(),
+                    fs_type: parts[2].to_string(),
+                });
+            }
+        }
+        
+        Ok(mounts)
+    }
+
+    /// Parse mergerfs source string to extract member paths
+    fn parse_mergerfs_sources(source: &str) -> Vec<String> {
+        // MergerFS source format: "/mnt/disk1:/mnt/disk2:/mnt/disk3"
+        source.split(':')
+            .map(|s| s.trim().to_string())
+            .filter(|s| !s.is_empty())
+            .collect()
+    }
+
+    /// Detect potential parity disks based on data member heuristics
+    fn detect_parity_disks(data_members: &[String]) -> Vec<String> {
+        let mut parity_disks = Vec::new();
+        
+        // Heuristic 1: Look for mount points with "parity" in the name
+        if let Ok(mounts) = Self::parse_proc_mounts() {
+            for mount in mounts {
+                if mount.mount_point.to_lowercase().contains("parity") && 
+                   (mount.fs_type == "xfs" || mount.fs_type == "ext4") {
+                    debug!("Detected parity disk by name: {}", mount.mount_point);
+                    parity_disks.push(mount.mount_point);
+                }
+            }
+        }
+        
+        // Heuristic 2: Look for sequential device pattern
+        // If data members are /mnt/disk1, /mnt/disk2, look for /mnt/disk* that's not in data
+        if parity_disks.is_empty() {
+            if let Some(pattern) = Self::extract_mount_pattern(data_members) {
+                if let Ok(mounts) = Self::parse_proc_mounts() {
+                    for mount in mounts {
+                        if mount.mount_point.starts_with(&pattern) && 
+                           !data_members.contains(&mount.mount_point) &&
+                           (mount.fs_type == "xfs" || mount.fs_type == "ext4") {
+                            debug!("Detected parity disk by pattern: {}", mount.mount_point);
+                            parity_disks.push(mount.mount_point);
+                        }
+                    }
+                }
+            }
+        }
+        
+        parity_disks
+    }
+
+    /// Extract common mount point pattern from data members
+    fn extract_mount_pattern(data_members: &[String]) -> Option<String> {
+        if data_members.is_empty() {
+            return None;
+        }
+        
+        // Find common prefix (e.g., "/mnt/disk" from "/mnt/disk1", "/mnt/disk2")
+        let first = &data_members[0];
+        if let Some(last_slash) = first.rfind('/') {
+            let base = &first[..last_slash + 1]; // Include the slash
+            
+            // Check if all members share this base
+            if data_members.iter().all(|member| member.starts_with(base)) {
+                return Some(base.to_string());
+            }
+        }
+        
+        None
+    }
+
+    /// Calculate disk temperature status using hysteresis thresholds
+    fn calculate_temperature_status(&self, metric_name: &str, temperature: f32, status_tracker: &mut StatusTracker) -> Status {
+        status_tracker.calculate_with_hysteresis(metric_name, temperature, &self.temperature_thresholds)
+    }
+
+
+    /// Get storage pools using auto-discovered topology or fallback to configuration
+    fn get_configured_storage_pools(&self) -> Result<Vec<StoragePool>> {
+        if let Some(ref topology) = self.storage_topology {
+            self.get_auto_discovered_storage_pools(topology)
+        } else {
+            self.get_legacy_configured_storage_pools()
+        }
+    }
+
+    /// Get storage pools from auto-discovered topology
+    fn get_auto_discovered_storage_pools(&self, topology: &StorageTopology) -> Result<Vec<StoragePool>> {
+        let mut storage_pools = Vec::new();
+
+        // Group single disks by physical drive for unified pool display
+        let grouped_disks = self.group_filesystems_by_physical_drive(&topology.single_disks)?;
+
+        // Process grouped single disks (each physical drive becomes a pool)
+        for (drive_name, filesystems) in grouped_disks {
+            // Create a unified pool for this physical drive
+            let pool = self.create_physical_drive_pool(&drive_name, &filesystems)?;
+            storage_pools.push(pool);
+        }
+
+        // IMPORTANT: Do not create individual filesystem pools when using auto-discovery
+        // All single disk filesystems should be grouped into physical drive pools above
+
+        // Process mergerfs pools (these remain as logical pools)
+        for pool_info in &topology.mergerfs_pools {
+            if let Ok((total_bytes, used_bytes)) = self.get_filesystem_info(&pool_info.mount_point) {
+                let available_bytes = total_bytes - used_bytes;
+                let usage_percent = if total_bytes > 0 {
+                    (used_bytes as f64 / total_bytes as f64) * 100.0
+                } else { 0.0 };
+
+                let size = self.bytes_to_human_readable(total_bytes);
+                let used = self.bytes_to_human_readable(used_bytes);
+                let available = self.bytes_to_human_readable(available_bytes);
+
+                // Collect all member and parity drives
+                let mut all_drives = Vec::new();
+                
+                // Add data member drives
+                for member in &pool_info.data_members {
+                    if let Some(devices) = self.detected_devices.get(member) {
+                        all_drives.extend(devices.clone());
+                    }
+                }
+                
+                // Add parity drives
+                for parity in &pool_info.parity_disks {
+                    if let Some(devices) = self.detected_devices.get(parity) {
+                        all_drives.extend(devices.clone());
+                    }
+                }
+
+                let underlying_drives = self.get_drive_info_for_devices(&all_drives)?;
+                
+                // Calculate pool health
+                let pool_health = self.calculate_mergerfs_pool_health(&pool_info.data_members, &pool_info.parity_disks, &underlying_drives);
+
+                // Generate pool name from mount point
+                let name = pool_info.mount_point.trim_start_matches('/').replace('/', "_");
+
+                storage_pools.push(StoragePool {
+                    name,
+                    mount_point: pool_info.mount_point.clone(),
+                    filesystem: "fuse.mergerfs".to_string(),
+                    pool_type: StoragePoolType::MergerfsPool {
+                        data_disks: pool_info.data_members.iter()
+                            .filter_map(|member| self.detected_devices.get(member).and_then(|devices| devices.first().cloned()))
+                            .collect(),
+                        parity_disks: pool_info.parity_disks.iter()
+                            .filter_map(|parity| self.detected_devices.get(parity).and_then(|devices| devices.first().cloned()))
+                            .collect(),
+                    },
+                    size,
+                    used,
+                    available,
+                    usage_percent: usage_percent as f32,
+                    underlying_drives,
+                    pool_health,
+                });
+
+                debug!("Auto-discovered mergerfs pool: {} with {} data + {} parity disks", 
+                       pool_info.mount_point, pool_info.data_members.len(), pool_info.parity_disks.len());
+            }
+        }
+
+        Ok(storage_pools)
+    }
+
+    /// Group filesystems by their backing physical drive
+    fn group_filesystems_by_physical_drive(&self, filesystems: &[MountInfo]) -> Result<std::collections::HashMap<String, Vec<MountInfo>>> {
+        let mut grouped = std::collections::HashMap::new();
+        
+        for fs in filesystems {
+            // Get the physical drive name for this mount point
+            if let Some(devices) = self.detected_devices.get(&fs.mount_point) {
+                if let Some(device_name) = devices.first() {
+                    // Extract base drive name from detected device
+                    let drive_name = Self::extract_base_device(device_name)
+                        .unwrap_or_else(|| device_name.clone());
+                    
+                    debug!("Grouping filesystem {} (device: {}) under drive: {}", 
+                           fs.mount_point, device_name, drive_name);
+                    
+                    grouped.entry(drive_name).or_insert_with(Vec::new).push(fs.clone());
+                }
+            }
+        }
+        
+        debug!("Filesystem grouping result: {} drives with filesystems: {:?}", 
+               grouped.len(), 
+               grouped.keys().collect::<Vec<_>>());
+        
+        Ok(grouped)
+    }
+
+    /// Create a physical drive pool containing multiple filesystems
+    fn create_physical_drive_pool(&self, drive_name: &str, filesystems: &[MountInfo]) -> Result<StoragePool> {
+        if filesystems.is_empty() {
+            return Err(anyhow::anyhow!("No filesystems for drive {}", drive_name));
+        }
+
+        // Calculate total usage across all filesystems on this drive
+        let mut total_capacity = 0u64;
+        let mut total_used = 0u64;
+        
+        for fs in filesystems {
+            if let Ok((capacity, used)) = self.get_filesystem_info(&fs.mount_point) {
+                total_capacity += capacity;
+                total_used += used;
+            }
+        }
+
+        let total_available = total_capacity.saturating_sub(total_used);
+        let usage_percent = if total_capacity > 0 {
+            (total_used as f64 / total_capacity as f64) * 100.0
+        } else { 0.0 };
+
+        // Get drive information for SMART data
+        let device_names = vec![drive_name.to_string()];
+        let underlying_drives = self.get_drive_info_for_devices(&device_names)?;
+
+        // Collect filesystem mount points for this drive
+        let filesystem_mount_points: Vec<String> = filesystems.iter()
+            .map(|fs| fs.mount_point.clone())
+            .collect();
+
+        Ok(StoragePool {
+            name: drive_name.to_string(),
+            mount_point: format!("(physical drive)"), // Special marker for physical drives
+            filesystem: "physical".to_string(),
+            pool_type: StoragePoolType::PhysicalDrive {
+                filesystems: filesystem_mount_points,
+            },
+            size: self.bytes_to_human_readable(total_capacity),
+            used: self.bytes_to_human_readable(total_used),
+            available: self.bytes_to_human_readable(total_available),
+            usage_percent: usage_percent as f32,
+            pool_health: if underlying_drives.iter().all(|d| d.health_status == "PASSED") {
+                PoolHealth::Healthy
+            } else {
+                PoolHealth::Critical
+            },
+            underlying_drives,
+        })
+    }
+
+    /// Calculate pool health specifically for mergerfs pools
+    fn calculate_mergerfs_pool_health(&self, data_members: &[String], parity_disks: &[String], drives: &[DriveInfo]) -> PoolHealth {
+        // Get device names for data and parity drives
+        let mut data_device_names = Vec::new();
+        let mut parity_device_names = Vec::new();
+        
+        for member in data_members {
+            if let Some(devices) = self.detected_devices.get(member) {
+                data_device_names.extend(devices.clone());
+            }
+        }
+        
+        for parity in parity_disks {
+            if let Some(devices) = self.detected_devices.get(parity) {
+                parity_device_names.extend(devices.clone());
+            }
+        }
+        
+        let failed_data = drives.iter()
+            .filter(|d| data_device_names.contains(&d.device) && d.health_status != "PASSED")
+            .count();
+        let failed_parity = drives.iter()
+            .filter(|d| parity_device_names.contains(&d.device) && d.health_status != "PASSED")
+            .count();
+        
+        match (failed_data, failed_parity) {
+            (0, 0) => PoolHealth::Healthy,
+            (1, 0) => PoolHealth::Degraded,  // Can recover with parity
+            (0, 1) => PoolHealth::Degraded,  // Lost parity protection
+            _ => PoolHealth::Critical,       // Multiple failures
+        }
+    }
+
+    /// Fallback to legacy configuration-based storage pools  
+    fn get_legacy_configured_storage_pools(&self) -> Result<Vec<StoragePool>> {
+        let mut storage_pools = Vec::new();
+        let mut processed_pools = std::collections::HashSet::new();
+
+        // Legacy implementation: use filesystem configuration
+        for fs_config in &self.config.filesystems {
+            if !fs_config.monitor {
+                continue;
+            }
+
+            let (pool_type, skip_in_single_mode) = self.determine_pool_type(&fs_config.storage_type);
+            
+            // Skip member disks if they're part of a pool
+            if skip_in_single_mode {
+                continue;
+            }
+
+            // Check if this pool was already processed (in case of multiple member disks)
+            let pool_key = match &pool_type {
+                StoragePoolType::MergerfsPool { .. } => {
+                    // For mergerfs pools, use the main mount point
+                    if fs_config.fs_type == "fuse.mergerfs" {
+                        fs_config.mount_point.clone()
+                    } else {
+                        continue; // Skip member disks
+                    }
+                }
+                _ => fs_config.mount_point.clone()
+            };
+
+            if processed_pools.contains(&pool_key) {
+                continue;
+            }
+            processed_pools.insert(pool_key.clone());
+
+            // Get filesystem stats for the mount point
+            match self.get_filesystem_info(&fs_config.mount_point) {
+                Ok((total_bytes, used_bytes)) => {
+                    let available_bytes = total_bytes - used_bytes;
+                    let usage_percent = if total_bytes > 0 {
+                        (used_bytes as f64 / total_bytes as f64) * 100.0
+                    } else { 0.0 };
+
+                    // Convert bytes to human-readable format
+                    let size = self.bytes_to_human_readable(total_bytes);
+                    let used = self.bytes_to_human_readable(used_bytes);
+                    let available = self.bytes_to_human_readable(available_bytes);
+
+                    // Get underlying drives based on pool type
+                    let underlying_drives = self.get_pool_drives(&pool_type, &fs_config.mount_point)?;
+                    
+                    // Calculate pool health
+                    let pool_health = self.calculate_pool_health(&pool_type, &underlying_drives);
+                    let drive_count = underlying_drives.len();
+
+                    storage_pools.push(StoragePool {
+                        name: fs_config.name.clone(),
+                        mount_point: fs_config.mount_point.clone(),
+                        filesystem: fs_config.fs_type.clone(),
+                        pool_type: pool_type.clone(),
+                        size,
+                        used,
+                        available,
+                        usage_percent: usage_percent as f32,
+                        underlying_drives,
+                        pool_health,
+                    });
+
+                    debug!(
+                        "Legacy configured storage pool '{}' ({:?}) at {} with {} drives, health: {:?}",
+                        fs_config.name, pool_type, fs_config.mount_point, drive_count, pool_health
+                    );
+                }
+                Err(e) => {
+                    debug!(
+                        "Failed to get filesystem info for storage pool '{}': {}",
+                        fs_config.name, e
+                    );
+                }
+            }
+        }
+
+        Ok(storage_pools)
+    }
+
+    /// Determine the storage pool type from configuration
+    fn determine_pool_type(&self, storage_type: &str) -> (StoragePoolType, bool) {
+        match storage_type {
+            "single" => (StoragePoolType::Single, false),
+            "mergerfs_pool" | "mergerfs" => {
+                // Find associated member disks
+                let data_disks = self.find_pool_member_disks("mergerfs_member");
+                let parity_disks = self.find_pool_member_disks("parity");
+                (StoragePoolType::MergerfsPool { data_disks, parity_disks }, false)
+            }
+            "mergerfs_member" => (StoragePoolType::Single, true), // Skip, part of pool
+            "parity" => (StoragePoolType::Single, true), // Skip, part of pool  
+            "raid1" | "raid5" | "raid6" => {
+                let member_disks = self.find_pool_member_disks(&format!("{}_member", storage_type));
+                (StoragePoolType::RaidArray { 
+                    level: storage_type.to_uppercase(), 
+                    member_disks, 
+                    spare_disks: Vec::new() 
+                }, false)
+            }
+            _ => (StoragePoolType::Single, false) // Default to single
+        }
+    }
+
+    /// Find member disks for a specific storage type
+    fn find_pool_member_disks(&self, member_type: &str) -> Vec<String> {
+        let mut member_disks = Vec::new();
+        
+        for fs_config in &self.config.filesystems {
+            if fs_config.storage_type == member_type && fs_config.monitor {
+                // Get device names for this mount point
+                if let Some(devices) = self.detected_devices.get(&fs_config.mount_point) {
+                    member_disks.extend(devices.clone());
+                }
+            }
+        }
+        
+        member_disks
+    }
+
+    /// Get drive information for a specific pool type
+    fn get_pool_drives(&self, pool_type: &StoragePoolType, mount_point: &str) -> Result<Vec<DriveInfo>> {
+        match pool_type {
+            StoragePoolType::Single => {
+                // Single disk - use detected devices for this mount point
+                let device_names = self.detected_devices.get(mount_point).cloned().unwrap_or_default();
+                self.get_drive_info_for_devices(&device_names)
+            }
+            StoragePoolType::PhysicalDrive { .. } => {
+                // Physical drive - get drive info for the drive directly (mount_point not used)
+                let device_names = vec![mount_point.to_string()];
+                self.get_drive_info_for_devices(&device_names)
+            }
+            StoragePoolType::MergerfsPool { data_disks, parity_disks } => {
+                // Mergerfs pool - collect all member drives
+                let mut all_disks = data_disks.clone();
+                all_disks.extend(parity_disks.clone());
+                self.get_drive_info_for_devices(&all_disks)
+            }
+            StoragePoolType::RaidArray { member_disks, spare_disks, .. } => {
+                // RAID array - collect member and spare drives
+                let mut all_disks = member_disks.clone();
+                all_disks.extend(spare_disks.clone());
+                self.get_drive_info_for_devices(&all_disks)
+            }
+            StoragePoolType::ZfsPool { .. } => {
+                // ZFS pool - use detected devices (future implementation)
+                let device_names = self.detected_devices.get(mount_point).cloned().unwrap_or_default();
+                self.get_drive_info_for_devices(&device_names)
+            }
+        }
+    }
+
+    /// Calculate pool health based on drive status and pool type
+    fn calculate_pool_health(&self, pool_type: &StoragePoolType, drives: &[DriveInfo]) -> PoolHealth {
+        match pool_type {
+            StoragePoolType::Single => {
+                // Single disk - health is just the drive health
+                if drives.is_empty() {
+                    PoolHealth::Unknown
+                } else if drives.iter().all(|d| d.health_status == "PASSED") {
+                    PoolHealth::Healthy
+                } else {
+                    PoolHealth::Critical
+                }
+            }
+            StoragePoolType::PhysicalDrive { .. } => {
+                // Physical drive - health is just the drive health (similar to Single)
+                if drives.is_empty() {
+                    PoolHealth::Unknown
+                } else if drives.iter().all(|d| d.health_status == "PASSED") {
+                    PoolHealth::Healthy
+                } else {
+                    PoolHealth::Critical
+                }
+            }
+            StoragePoolType::MergerfsPool { data_disks, parity_disks } => {
+                let failed_data = drives.iter()
+                    .filter(|d| data_disks.contains(&d.device) && d.health_status != "PASSED")
+                    .count();
+                let failed_parity = drives.iter()
+                    .filter(|d| parity_disks.contains(&d.device) && d.health_status != "PASSED")
+                    .count();
+                
+                match (failed_data, failed_parity) {
+                    (0, 0) => PoolHealth::Healthy,
+                    (1, 0) => PoolHealth::Degraded,  // Can recover with parity
+                    (0, 1) => PoolHealth::Degraded,  // Lost parity protection
+                    _ => PoolHealth::Critical,       // Multiple failures
+                }
+            }
+            StoragePoolType::RaidArray { level, .. } => {
+                let failed_drives = drives.iter().filter(|d| d.health_status != "PASSED").count();
+                
+                // Basic RAID health logic (can be enhanced per RAID level)
+                match failed_drives {
+                    0 => PoolHealth::Healthy,
+                    1 if level.contains('1') || level.contains('5') || level.contains('6') => PoolHealth::Degraded,
+                    _ => PoolHealth::Critical,
+                }
+            }
+            StoragePoolType::ZfsPool { .. } => {
+                // ZFS health would require zpool status parsing (future)
+                if drives.iter().all(|d| d.health_status == "PASSED") {
+                    PoolHealth::Healthy
+                } else {
+                    PoolHealth::Degraded
+                }
+            }
+        }
+    }
+
+    /// Get drive information for a list of device names
+    fn get_drive_info_for_devices(&self, device_names: &[String]) -> Result<Vec<DriveInfo>> {
+        let mut drives = Vec::new();
+        
+        for device_name in device_names {
+            let device_path = format!("/dev/{}", device_name);
+            
+            // Get SMART data for this drive
+            let (health_status, temperature, wear_level) = self.get_smart_data(&device_path);
+            
+            drives.push(DriveInfo {
+                device: device_name.clone(),
+                health_status: health_status.clone(),
+                temperature,
+                wear_level,
+            });
+            
+            debug!(
+                "Drive info for {}: health={}, temp={:?}°C, wear={:?}%",
+                device_name, health_status, temperature, wear_level
+            );
+        }
+        
+        Ok(drives)
+    }
+
+    /// Get SMART data for a drive (health, temperature, wear level)
+    fn get_smart_data(&self, device_path: &str) -> (String, Option<f32>, Option<f32>) {
+        // Try to get SMART data using smartctl
+        let output = Command::new("sudo")
+            .arg("smartctl")
+            .arg("-a")
+            .arg(device_path)
+            .output();
+            
+        match output {
+            Ok(result) if result.status.success() => {
+                let stdout = String::from_utf8_lossy(&result.stdout);
+                
+                // Parse health status
+                let health = if stdout.contains("PASSED") {
+                    "PASSED".to_string()
+                } else if stdout.contains("FAILED") {
+                    "FAILED".to_string()
+                } else {
+                    "UNKNOWN".to_string()
+                };
+                
+                // Parse temperature (look for various temperature indicators)
+                let temperature = self.parse_temperature_from_smart(&stdout);
+                
+                // Parse wear level (for SSDs)
+                let wear_level = self.parse_wear_level_from_smart(&stdout);
+                
+                (health, temperature, wear_level)
+            }
+            _ => {
+                debug!("Failed to get SMART data for {}", device_path);
+                ("UNKNOWN".to_string(), None, None)
+            }
+        }
+    }
+
+    /// Parse temperature from SMART output
+    fn parse_temperature_from_smart(&self, smart_output: &str) -> Option<f32> {
+        for line in smart_output.lines() {
+            // Look for temperature in various formats
+            if line.contains("Temperature_Celsius") || line.contains("Temperature") {
+                let parts: Vec<&str> = line.split_whitespace().collect();
+                if parts.len() >= 10 {
+                    if let Ok(temp) = parts[9].parse::<f32>() {
+                        return Some(temp);
+                    }
+                }
+            }
+            // NVMe drives might show temperature differently
+            if line.contains("temperature:") {
+                if let Some(temp_part) = line.split("temperature:").nth(1) {
+                    if let Some(temp_str) = temp_part.split_whitespace().next() {
+                        if let Ok(temp) = temp_str.parse::<f32>() {
+                            return Some(temp);
+                        }
+                    }
+                }
+            }
+        }
+        None
+    }
+
+    /// Parse wear level from SMART output (SSD wear leveling)
+    /// Supports both NVMe and SATA SSD wear indicators
+    fn parse_wear_level_from_smart(&self, smart_output: &str) -> Option<f32> {
+        for line in smart_output.lines() {
+            let line = line.trim();
+            
+            // NVMe drives - direct percentage used
+            if line.contains("Percentage Used:") {
+                if let Some(wear_part) = line.split("Percentage Used:").nth(1) {
+                    if let Some(wear_str) = wear_part.split('%').next() {
+                        if let Ok(wear) = wear_str.trim().parse::<f32>() {
+                            return Some(wear);
+                        }
+                    }
+                }
+            }
+            
+            // SATA SSD attributes - parse SMART table format
+            // Format: ID ATTRIBUTE_NAME FLAG VALUE WORST THRESH TYPE UPDATED WHEN_FAILED RAW_VALUE
+            let parts: Vec<&str> = line.split_whitespace().collect();
+            if parts.len() >= 10 {
+                // SSD Life Left / Percent Lifetime Remaining (higher = less wear)
+                if line.contains("SSD_Life_Left") || line.contains("Percent_Lifetime_Remain") {
+                    if let Ok(remaining) = parts[3].parse::<f32>() { // VALUE column
+                        return Some(100.0 - remaining); // Convert remaining to used
+                    }
+                }
+                
+                // Media Wearout Indicator (lower = more wear, normalize to 0-100)
+                if line.contains("Media_Wearout_Indicator") {
+                    if let Ok(remaining) = parts[3].parse::<f32>() { // VALUE column
+                        return Some(100.0 - remaining); // Convert remaining to used
+                    }
+                }
+                
+                // Wear Leveling Count (higher = less wear, but varies by manufacturer)
+                if line.contains("Wear_Leveling_Count") {
+                    if let Ok(wear_count) = parts[3].parse::<f32>() { // VALUE column
+                        // Most SSDs: 100 = new, decreases with wear
+                        if wear_count <= 100.0 {
+                            return Some(100.0 - wear_count);
+                        }
+                    }
+                }
+                
+                // Total LBAs Written - calculate against typical endurance if available
+                // This is more complex and manufacturer-specific, so we skip for now
+            }
+        }
+        None
+    }
+
+    /// Convert bytes to human-readable format
+    fn bytes_to_human_readable(&self, bytes: u64) -> String {
+        const UNITS: &[&str] = &["B", "K", "M", "G", "T"];
+        let mut size = bytes as f64;
+        let mut unit_index = 0;
+
+        while size >= 1024.0 && unit_index < UNITS.len() - 1 {
+            size /= 1024.0;
+            unit_index += 1;
+        }
+
+        if unit_index == 0 {
+            format!("{:.0}{}", size, UNITS[unit_index])
+        } else {
+            format!("{:.1}{}", size, UNITS[unit_index])
+        }
+    }
+
+    /// Convert bytes to gigabytes
+    fn bytes_to_gb(&self, bytes: u64) -> f32 {
+        bytes as f32 / (1024.0 * 1024.0 * 1024.0)
+    }
+
+    /// Detect device backing a mount point using lsblk (static version for startup)
+    fn detect_device_for_mount_point_static(mount_point: &str) -> Result<Vec<String>> {
+        let output = Command::new("lsblk")
+            .args(&["-n", "-o", "NAME,MOUNTPOINT"])
+            .output()?;
+        
+        if !output.status.success() {
+            return Ok(Vec::new());
+        }
+        
+        let output_str = String::from_utf8_lossy(&output.stdout);
+        
+        for line in output_str.lines() {
+            let parts: Vec<&str> = line.split_whitespace().collect();
+            if parts.len() >= 2 && parts[1] == mount_point {
+                // Remove tree symbols and extract device name (e.g., "├─nvme0n1p2" -> "nvme0n1p2")
+                let device_name = parts[0]
+                    .trim_start_matches('├')
+                    .trim_start_matches('└')
+                    .trim_start_matches('─')
+                    .trim();
+                
+                // Extract base device name (e.g., "nvme0n1p2" -> "nvme0n1")
+                if let Some(base_device) = Self::extract_base_device(device_name) {
+                    return Ok(vec![base_device]);
+                }
+            }
+        }
+        
+        Ok(Vec::new())
+    }
+
+    /// Extract base device name from partition (e.g., "nvme0n1p2" -> "nvme0n1", "sda1" -> "sda")
+    fn extract_base_device(device_name: &str) -> Option<String> {
+        // Handle NVMe devices (nvme0n1p1 -> nvme0n1)
+        if device_name.starts_with("nvme") {
+            if let Some(p_pos) = device_name.find('p') {
+                return Some(device_name[..p_pos].to_string());
+            }
+        }
+        
+        // Handle traditional devices (sda1 -> sda)
+        if device_name.len() > 1 {
+            let chars: Vec<char> = device_name.chars().collect();
+            let mut end_idx = chars.len();
+            
+            // Find where the device name ends and partition number begins
+            for (i, &c) in chars.iter().enumerate().rev() {
+                if !c.is_ascii_digit() {
+                    end_idx = i + 1;
+                    break;
+                }
+            }
+            
+            if end_idx > 0 && end_idx < chars.len() {
+                return Some(chars[..end_idx].iter().collect());
+            }
+        }
+        
+        // If no partition detected, return as-is
+        Some(device_name.to_string())
+    }
+
+
+    /// Get filesystem info using df command
+    fn get_filesystem_info(&self, path: &str) -> Result<(u64, u64)> {
+        let output = Command::new("df")
+            .arg("--block-size=1")
+            .arg(path)
+            .output()?;
+
+        if !output.status.success() {
+            return Err(anyhow::anyhow!("df command failed for {}", path));
+        }
+
+        let output_str = String::from_utf8(output.stdout)?;
+        let lines: Vec<&str> = output_str.lines().collect();
+
+        if lines.len() < 2 {
+            return Err(anyhow::anyhow!("Unexpected df output format"));
+        }
+
+        let fields: Vec<&str> = lines[1].split_whitespace().collect();
+        if fields.len() < 4 {
+            return Err(anyhow::anyhow!("Unexpected df fields count"));
+        }
+
+        let total_bytes = fields[1].parse::<u64>()?;
+        let used_bytes = fields[2].parse::<u64>()?;
+
+        Ok((total_bytes, used_bytes))
+    }
+
+
+    /// Parse size string (e.g., "120G", "45M") to GB value
+    fn parse_size_to_gb(&self, size_str: &str) -> f32 {
+        let size_str = size_str.trim();
+        if size_str.is_empty() || size_str == "-" {
+            return 0.0;
+        }
+
+        // Extract numeric part and unit
+        let (num_str, unit) = if let Some(last_char) = size_str.chars().last() {
+            if last_char.is_alphabetic() {
+                let num_part = &size_str[..size_str.len() - 1];
+                let unit_part = &size_str[size_str.len() - 1..];
+                (num_part, unit_part)
+            } else {
+                (size_str, "")
+            }
+        } else {
+            (size_str, "")
+        };
+
+        let number: f32 = num_str.parse().unwrap_or(0.0);
+
+        match unit.to_uppercase().as_str() {
+            "T" | "TB" => number * 1024.0,
+            "G" | "GB" => number,
+            "M" | "MB" => number / 1024.0,
+            "K" | "KB" => number / (1024.0 * 1024.0),
+            "B" | "" => number / (1024.0 * 1024.0 * 1024.0),
+            _ => number, // Assume GB if unknown unit
+        }
+    }
+}
+
+#[async_trait]
+impl Collector for DiskCollector {
+
+    async fn collect(&self, status_tracker: &mut StatusTracker) -> Result<Vec<Metric>, CollectorError> {
+        let start_time = Instant::now();
+        debug!("Collecting storage pool and individual drive metrics");
+
+        let mut metrics = Vec::new();
+
+        // Get configured storage pools with individual drive data
+        let storage_pools = match self.get_configured_storage_pools() {
+            Ok(pools) => {
+                debug!("Found {} storage pools", pools.len());
+                pools
+            }
+            Err(e) => {
+                debug!("Failed to get storage pools: {}", e);
+                Vec::new()
+            }
+        };
+
+        // Generate metrics for each storage pool and its underlying drives
+        for storage_pool in &storage_pools {
+            let timestamp = chrono::Utc::now().timestamp() as u64;
+
+            // Storage pool overall metrics
+            let pool_name = &storage_pool.name;
+            
+            // Parse size strings to get actual values for calculations
+            let size_gb = self.parse_size_to_gb(&storage_pool.size);
+            let used_gb = self.parse_size_to_gb(&storage_pool.used);
+            let avail_gb = self.parse_size_to_gb(&storage_pool.available);
+
+            // Calculate status based on configured thresholds and pool health
+            let usage_status = if storage_pool.usage_percent >= self.config.usage_critical_percent {
+                Status::Critical
+            } else if storage_pool.usage_percent >= self.config.usage_warning_percent {
+                Status::Warning
+            } else {
+                Status::Ok
+            };
+
+            let pool_status = match storage_pool.pool_health {
+                PoolHealth::Critical => Status::Critical,
+                PoolHealth::Degraded => Status::Warning,
+                PoolHealth::Rebuilding => Status::Warning,
+                PoolHealth::Healthy => usage_status,
+                PoolHealth::Unknown => Status::Unknown,
+            };
+
+            // Storage pool info metrics
+            metrics.push(Metric {
+                name: format!("disk_{}_mount_point", pool_name),
+                value: MetricValue::String(storage_pool.mount_point.clone()),
+                unit: None,
+                description: Some(format!("Mount: {}", storage_pool.mount_point)),
+                status: Status::Ok,
+                timestamp,
+            });
+
+            metrics.push(Metric {
+                name: format!("disk_{}_filesystem", pool_name),
+                value: MetricValue::String(storage_pool.filesystem.clone()),
+                unit: None,
+                description: Some(format!("FS: {}", storage_pool.filesystem)),
+                status: Status::Ok,
+                timestamp,
+            });
+
+            // Enhanced pool type information
+            let pool_type_str = match &storage_pool.pool_type {
+                StoragePoolType::Single => "single".to_string(),
+                StoragePoolType::PhysicalDrive { filesystems } => {
+                    format!("drive ({})", filesystems.len())
+                }
+                StoragePoolType::MergerfsPool { data_disks, parity_disks } => {
+                    format!("mergerfs ({}+{})", data_disks.len(), parity_disks.len())
+                }
+                StoragePoolType::RaidArray { level, member_disks, spare_disks } => {
+                    format!("{} ({}+{})", level, member_disks.len(), spare_disks.len())
+                }
+                StoragePoolType::ZfsPool { pool_name, .. } => {
+                    format!("zfs ({})", pool_name)
+                }
+            };
+
+            metrics.push(Metric {
+                name: format!("disk_{}_pool_type", pool_name),
+                value: MetricValue::String(pool_type_str.clone()),
+                unit: None,
+                description: Some(format!("Type: {}", pool_type_str)),
+                status: Status::Ok,
+                timestamp,
+            });
+
+            // Pool health status
+            let health_str = match storage_pool.pool_health {
+                PoolHealth::Healthy => "healthy",
+                PoolHealth::Degraded => "degraded", 
+                PoolHealth::Critical => "critical",
+                PoolHealth::Rebuilding => "rebuilding",
+                PoolHealth::Unknown => "unknown",
+            };
+
+            metrics.push(Metric {
+                name: format!("disk_{}_pool_health", pool_name),
+                value: MetricValue::String(health_str.to_string()),
+                unit: None,
+                description: Some(format!("Health: {}", health_str)),
+                status: pool_status,
+                timestamp,
+            });
+
+            // Storage pool size metrics
+            metrics.push(Metric {
+                name: format!("disk_{}_total_gb", pool_name),
+                value: MetricValue::Float(size_gb),
+                unit: Some("GB".to_string()),
+                description: Some(format!("Total: {}", storage_pool.size)),
+                status: Status::Ok,
+                timestamp,
+            });
+
+            metrics.push(Metric {
+                name: format!("disk_{}_used_gb", pool_name),
+                value: MetricValue::Float(used_gb),
+                unit: Some("GB".to_string()),
+                description: Some(format!("Used: {}", storage_pool.used)),
+                status: pool_status,
+                timestamp,
+            });
+
+            metrics.push(Metric {
+                name: format!("disk_{}_available_gb", pool_name),
+                value: MetricValue::Float(avail_gb),
+                unit: Some("GB".to_string()),
+                description: Some(format!("Available: {}", storage_pool.available)),
+                status: Status::Ok,
+                timestamp,
+            });
+
+            metrics.push(Metric {
+                name: format!("disk_{}_usage_percent", pool_name),
+                value: MetricValue::Float(storage_pool.usage_percent),
+                unit: Some("%".to_string()),
+                description: Some(format!("Usage: {:.1}%", storage_pool.usage_percent)),
+                status: pool_status,
+                timestamp,
+            });
+
+            // Individual drive metrics for this storage pool
+            for drive in &storage_pool.underlying_drives {
+                // Drive health status
+                metrics.push(Metric {
+                    name: format!("disk_{}_{}_health", pool_name, drive.device),
+                    value: MetricValue::String(drive.health_status.clone()),
+                    unit: None,
+                    description: Some(format!("{}: {}", drive.device, drive.health_status)),
+                    status: if drive.health_status == "PASSED" { Status::Ok } 
+                            else if drive.health_status == "FAILED" { Status::Critical }
+                            else { Status::Unknown },
+                    timestamp,
+                });
+
+                // Drive temperature
+                if let Some(temp) = drive.temperature {
+                    let temp_status = self.calculate_temperature_status(
+                        &format!("disk_{}_{}_temperature", pool_name, drive.device),
+                        temp,
+                        status_tracker
+                    );
+                    
+                    metrics.push(Metric {
+                        name: format!("disk_{}_{}_temperature", pool_name, drive.device),
+                        value: MetricValue::Float(temp),
+                        unit: Some("°C".to_string()),
+                        description: Some(format!("{}: {:.0}°C", drive.device, temp)),
+                        status: temp_status,
+                        timestamp,
+                    });
+                }
+
+                // Drive wear level (for SSDs)
+                if let Some(wear) = drive.wear_level {
+                    let wear_status = if wear >= self.config.wear_critical_percent { Status::Critical }
+                                     else if wear >= self.config.wear_warning_percent { Status::Warning }
+                                     else { Status::Ok };
+                    
+                    metrics.push(Metric {
+                        name: format!("disk_{}_{}_wear_percent", pool_name, drive.device),
+                        value: MetricValue::Float(wear),
+                        unit: Some("%".to_string()),
+                        description: Some(format!("{}: {:.0}% wear", drive.device, wear)),
+                        status: wear_status,
+                        timestamp,
+                    });
+                }
+            }
+
+            // Individual filesystem metrics for PhysicalDrive pools
+            if let StoragePoolType::PhysicalDrive { filesystems } = &storage_pool.pool_type {
+                for filesystem_mount in filesystems {
+                    if let Ok((total_bytes, used_bytes)) = self.get_filesystem_info(filesystem_mount) {
+                        let available_bytes = total_bytes - used_bytes;
+                        let usage_percent = if total_bytes > 0 {
+                            (used_bytes as f64 / total_bytes as f64) * 100.0
+                        } else { 0.0 };
+
+                        let filesystem_name = if filesystem_mount == "/" {
+                            "root".to_string()
+                        } else {
+                            filesystem_mount.trim_start_matches('/').replace('/', "_")
+                        };
+
+                        // Calculate filesystem status based on usage
+                        let fs_status = if usage_percent >= self.config.usage_critical_percent as f64 {
+                            Status::Critical
+                        } else if usage_percent >= self.config.usage_warning_percent as f64 {
+                            Status::Warning
+                        } else {
+                            Status::Ok
+                        };
+
+                        // Filesystem usage metrics
+                        metrics.push(Metric {
+                            name: format!("disk_{}_fs_{}_usage_percent", pool_name, filesystem_name),
+                            value: MetricValue::Float(usage_percent as f32),
+                            unit: Some("%".to_string()),
+                            description: Some(format!("{}: {:.0}%", filesystem_mount, usage_percent)),
+                            status: fs_status.clone(),
+                            timestamp,
+                        });
+
+                        metrics.push(Metric {
+                            name: format!("disk_{}_fs_{}_used_gb", pool_name, filesystem_name),
+                            value: MetricValue::Float(self.bytes_to_gb(used_bytes)),
+                            unit: Some("GB".to_string()),
+                            description: Some(format!("{}: {}GB used", filesystem_mount, self.bytes_to_human_readable(used_bytes))),
+                            status: Status::Ok,
+                            timestamp,
+                        });
+
+                        metrics.push(Metric {
+                            name: format!("disk_{}_fs_{}_total_gb", pool_name, filesystem_name),
+                            value: MetricValue::Float(self.bytes_to_gb(total_bytes)),
+                            unit: Some("GB".to_string()),
+                            description: Some(format!("{}: {}GB total", filesystem_mount, self.bytes_to_human_readable(total_bytes))),
+                            status: Status::Ok,
+                            timestamp,
+                        });
+
+                        metrics.push(Metric {
+                            name: format!("disk_{}_fs_{}_available_gb", pool_name, filesystem_name),
+                            value: MetricValue::Float(self.bytes_to_gb(available_bytes)),
+                            unit: Some("GB".to_string()),
+                            description: Some(format!("{}: {}GB available", filesystem_mount, self.bytes_to_human_readable(available_bytes))),
+                            status: Status::Ok,
+                            timestamp,
+                        });
+
+                        metrics.push(Metric {
+                            name: format!("disk_{}_fs_{}_mount_point", pool_name, filesystem_name),
+                            value: MetricValue::String(filesystem_mount.clone()),
+                            unit: None,
+                            description: Some(format!("Mount: {}", filesystem_mount)),
+                            status: Status::Ok,
+                            timestamp,
+                        });
+                    }
+                }
+            }
+        }
+
+        // Add storage pool count metric
+        metrics.push(Metric {
+            name: "disk_count".to_string(),
+            value: MetricValue::Integer(storage_pools.len() as i64),
+            unit: None,
+            description: Some(format!("Total storage pools: {}", storage_pools.len())),
+            status: Status::Ok,
+            timestamp: chrono::Utc::now().timestamp() as u64,
+        });
+
+
+        let collection_time = start_time.elapsed();
+        debug!(
+            "Multi-disk collection completed in {:?} with {} metrics",
+            collection_time,
+            metrics.len()
+        );
+
+        Ok(metrics)
+    }
+}

dashboard/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "cm-dashboard"
-version = "0.1.97"
+version = "0.1.110"
 edition = "2021"
 
 [dependencies]

dashboard/src/ui/mod.rs

@@ -589,12 +589,13 @@ impl TuiApp {
         // Split the title bar into left and right sections
         let chunks = Layout::default()
             .direction(Direction::Horizontal)
-            .constraints([Constraint::Length(15), Constraint::Min(0)])
+            .constraints([Constraint::Length(22), Constraint::Min(0)])
             .split(area);
 
-        // Left side: "cm-dashboard" text
+        // Left side: "cm-dashboard" text with version
+        let title_text = format!(" cm-dashboard v{}", env!("CARGO_PKG_VERSION"));
         let left_span = Span::styled(
-            " cm-dashboard", 
+            &title_text, 
             Style::default().fg(Theme::background()).bg(background_color).add_modifier(Modifier::BOLD)
         );
         let left_title = Paragraph::new(Line::from(vec![left_span]))
@@ -666,32 +667,27 @@ impl TuiApp {
             return host_summary_metric.status;
         }
 
-        // Fallback to old aggregation logic with proper Pending handling
+        // Rewritten status aggregation - only Critical, Warning, or OK for top bar
         let mut has_critical = false;
         let mut has_warning = false;
-        let mut ok_count = 0;
 
         for metric in &metrics {
             match metric.status {
                 Status::Critical => has_critical = true,
                 Status::Warning => has_warning = true,
-                Status::Pending => ok_count += 1, // Treat pending as OK for aggregation
-                Status::Ok => ok_count += 1,
-                Status::Inactive => ok_count += 1, // Treat inactive as OK for aggregation
-                Status::Unknown => ok_count += 1, // Treat unknown as OK for aggregation
-                Status::Offline => {}, // Ignore offline for aggregation
+                // Treat all other statuses as OK for top bar aggregation
+                Status::Ok | Status::Pending | Status::Inactive | Status::Unknown => {},
+                Status::Offline => {}, // Ignore offline
             }
         }
 
-        // Priority order: Critical > Warning > Ok > Unknown (no Pending)
+        // Only return Critical, Warning, or OK - no other statuses
         if has_critical {
             Status::Critical
         } else if has_warning {
             Status::Warning
-        } else if ok_count > 0 {
-            Status::Ok
         } else {
-            Status::Unknown
+            Status::Ok
         }
     }
 

dashboard/src/ui/widgets/system.rs

@@ -45,12 +45,15 @@ pub struct SystemWidget {
 struct StoragePool {
     name: String,
     mount_point: String,
-    pool_type: String, // "Single", "Raid0", etc.
+    pool_type: String, // "single", "mergerfs (2+1)", "RAID5 (3+1)", etc.
+    pool_health: Option<String>, // "healthy", "degraded", "critical", "rebuilding"
     drives: Vec<StorageDrive>,
+    filesystems: Vec<FileSystem>, // For physical drive pools: individual filesystem children
     usage_percent: Option<f32>,
     used_gb: Option<f32>,
     total_gb: Option<f32>,
     status: Status,
+    health_status: Status, // Separate status for pool health vs usage
 }
 
 #[derive(Clone)]
@@ -61,6 +64,16 @@ struct StorageDrive {
     status: Status,
 }
 
+#[derive(Clone)]
+struct FileSystem {
+    mount_point: String,
+    usage_percent: Option<f32>,
+    used_gb: Option<f32>,
+    total_gb: Option<f32>,
+    available_gb: Option<f32>,
+    status: Status,
+}
+
 impl SystemWidget {
     pub fn new() -> Self {
         Self {
@@ -155,12 +168,15 @@ impl SystemWidget {
                     let pool = pools.entry(pool_name.clone()).or_insert_with(|| StoragePool {
                         name: pool_name.clone(),
                         mount_point: mount_point.clone(),
-                        pool_type: "Single".to_string(), // Default, could be enhanced
+                        pool_type: "single".to_string(), // Default, will be updated
+                        pool_health: None,
                         drives: Vec::new(),
+                        filesystems: Vec::new(),
                         usage_percent: None,
                         used_gb: None,
                         total_gb: None,
                         status: Status::Unknown,
+                        health_status: Status::Unknown,
                     });
 
                     // Parse different metric types
@@ -177,6 +193,15 @@ impl SystemWidget {
                         if let MetricValue::Float(total) = metric.value {
                             pool.total_gb = Some(total);
                         }
+                    } else if metric.name.contains("_pool_type") {
+                        if let MetricValue::String(pool_type) = &metric.value {
+                            pool.pool_type = pool_type.clone();
+                        }
+                    } else if metric.name.contains("_pool_health") {
+                        if let MetricValue::String(health) = &metric.value {
+                            pool.pool_health = Some(health.clone());
+                            pool.health_status = metric.status.clone();
+                        }
                     } else if metric.name.contains("_temperature") {
                         if let Some(drive_name) = self.extract_drive_name(&metric.name) {
                             // Find existing drive or create new one
@@ -217,6 +242,91 @@ impl SystemWidget {
                                 }
                             }
                         }
+                    } else if metric.name.contains("_fs_") {
+                        // Handle filesystem metrics for physical drive pools (disk_{pool}_fs_{fs_name}_{metric})
+                        if let (Some(fs_name), Some(metric_type)) = self.extract_filesystem_metric(&metric.name) {
+                            // Find or create filesystem entry
+                            let fs_exists = pool.filesystems.iter().any(|fs| {
+                                let fs_id = if fs.mount_point == "/" { 
+                                    "root".to_string() 
+                                } else { 
+                                    fs.mount_point.trim_start_matches('/').replace('/', "_") 
+                                };
+                                fs_id == fs_name
+                            });
+
+                            if !fs_exists {
+                                // Create filesystem entry with correct mount point
+                                let mount_point = if metric_type == "mount_point" {
+                                    if let MetricValue::String(mount) = &metric.value {
+                                        mount.clone()
+                                    } else {
+                                        // Fallback: handle special cases
+                                        if fs_name == "root" {
+                                            "/".to_string()
+                                        } else {
+                                            format!("/{}", fs_name.replace('_', "/"))
+                                        }
+                                    }
+                                } else {
+                                    // Fallback for non-mount_point metrics: generate mount point from fs_name
+                                    if fs_name == "root" {
+                                        "/".to_string()
+                                    } else {
+                                        format!("/{}", fs_name.replace('_', "/"))
+                                    }
+                                };
+
+                                pool.filesystems.push(FileSystem {
+                                    mount_point,
+                                    usage_percent: None,
+                                    used_gb: None,
+                                    total_gb: None,
+                                    available_gb: None,
+                                    status: Status::Unknown,
+                                });
+                            }
+
+                            // Update the filesystem with the metric value
+                            if let Some(filesystem) = pool.filesystems.iter_mut().find(|fs| {
+                                let fs_id = if fs.mount_point == "/" { 
+                                    "root".to_string() 
+                                } else { 
+                                    fs.mount_point.trim_start_matches('/').replace('/', "_") 
+                                };
+                                fs_id == fs_name
+                            }) {
+                                match metric_type.as_str() {
+                                    "usage_percent" => {
+                                        if let MetricValue::Float(usage) = metric.value {
+                                            filesystem.usage_percent = Some(usage);
+                                            filesystem.status = metric.status.clone();
+                                        }
+                                    }
+                                    "used_gb" => {
+                                        if let MetricValue::Float(used) = metric.value {
+                                            filesystem.used_gb = Some(used);
+                                        }
+                                    }
+                                    "total_gb" => {
+                                        if let MetricValue::Float(total) = metric.value {
+                                            filesystem.total_gb = Some(total);
+                                        }
+                                    }
+                                    "available_gb" => {
+                                        if let MetricValue::Float(available) = metric.value {
+                                            filesystem.available_gb = Some(available);
+                                        }
+                                    }
+                                    "mount_point" => {
+                                        if let MetricValue::String(mount) = &metric.value {
+                                            filesystem.mount_point = mount.clone();
+                                        }
+                                    }
+                                    _ => {}
+                                }
+                            }
+                        }
                     }
                 }
             }
@@ -243,10 +353,17 @@ impl SystemWidget {
                     return Some(metric_name[5..drive_start].to_string()); // Skip "disk_"
                 }
             }
+            // Handle filesystem metrics: disk_{pool}_fs_{filesystem}_{metric}
+            else if metric_name.contains("_fs_") {
+                if let Some(fs_pos) = metric_name.find("_fs_") {
+                    return Some(metric_name[5..fs_pos].to_string()); // Skip "disk_", extract pool name before "_fs_"
+                }
+            }
             // For pool-level metrics (usage_percent, used_gb, total_gb), take everything before the metric suffix
             else if let Some(suffix_pos) = metric_name.rfind("_usage_percent")
                 .or_else(|| metric_name.rfind("_used_gb"))
-                .or_else(|| metric_name.rfind("_total_gb")) {
+                .or_else(|| metric_name.rfind("_total_gb"))
+                .or_else(|| metric_name.rfind("_available_gb")) {
                 return Some(metric_name[5..suffix_pos].to_string()); // Skip "disk_"
             }
             // Fallback to old behavior for unknown patterns
@@ -259,6 +376,28 @@ impl SystemWidget {
         None
     }
 
+    /// Extract filesystem name and metric type from filesystem metric names
+    /// Pattern: disk_{pool}_fs_{filesystem_name}_{metric_type}
+    fn extract_filesystem_metric(&self, metric_name: &str) -> (Option<String>, Option<String>) {
+        if metric_name.starts_with("disk_") && metric_name.contains("_fs_") {
+            // Find the _fs_ part
+            if let Some(fs_start) = metric_name.find("_fs_") {
+                let after_fs = &metric_name[fs_start + 4..]; // Skip "_fs_"
+                
+                // Look for known metric suffixes (these can contain underscores)
+                let known_suffixes = ["usage_percent", "used_gb", "total_gb", "available_gb", "mount_point"];
+                
+                for suffix in known_suffixes {
+                    if after_fs.ends_with(suffix) {
+                        let fs_name = after_fs[..after_fs.len() - suffix.len() - 1].to_string(); // Remove suffix + underscore
+                        return (Some(fs_name), Some(suffix.to_string()));
+                    }
+                }
+            }
+        }
+        (None, None)
+    }
+
     /// Extract drive name from disk metric name  
     fn extract_drive_name(&self, metric_name: &str) -> Option<String> {
         // Pattern: disk_{pool_name}_{drive_name}_{metric_type}
@@ -277,73 +416,208 @@ impl SystemWidget {
         None
     }
 
-    /// Render storage section with tree structure
+    /// Render storage section with enhanced tree structure
     fn render_storage(&self) -> Vec<Line<'_>> {
         let mut lines = Vec::new();
 
         for pool in &self.storage_pools {
-            // Pool header line
-            let usage_text = match (pool.usage_percent, pool.used_gb, pool.total_gb) {
-                (Some(pct), Some(used), Some(total)) => {
-                    format!("{:.0}% {:.1}GB/{:.1}GB", pct, used, total)
-                }
-                _ => "—% —GB/—GB".to_string(),
-            };
-            
-            let pool_label = if pool.pool_type.to_lowercase() == "single" {
+            // Pool header line with type and health
+            let pool_label = if pool.pool_type == "single" {
                 format!("{}:", pool.mount_point)
             } else {
                 format!("{} ({}):", pool.mount_point, pool.pool_type)
             };
             let pool_spans = StatusIcons::create_status_spans(
-                pool.status.clone(),
+                pool.health_status.clone(),
                 &pool_label
             );
             lines.push(Line::from(pool_spans));
 
-            // Drive lines with tree structure
-            let has_usage_line = pool.usage_percent.is_some();
-            for (i, drive) in pool.drives.iter().enumerate() {
-                let is_last_drive = i == pool.drives.len() - 1;
-                let tree_symbol = if is_last_drive && !has_usage_line { "└─" } else { "├─" };
-                
-                let mut drive_info = Vec::new();
-                if let Some(temp) = drive.temperature {
-                    drive_info.push(format!("T: {:.0}C", temp));
+            // Pool health line (for multi-disk pools)
+            if pool.pool_type != "single" {
+                if let Some(health) = &pool.pool_health {
+                    let health_text = match health.as_str() {
+                        "healthy" => format!("Pool Status: {} Healthy", 
+                            if pool.drives.len() > 1 { format!("({} drives)", pool.drives.len()) } else { String::new() }),
+                        "degraded" => "Pool Status: ⚠ Degraded".to_string(),
+                        "critical" => "Pool Status: ✗ Critical".to_string(), 
+                        "rebuilding" => "Pool Status: ⟳ Rebuilding".to_string(),
+                        _ => format!("Pool Status: ? {}", health),
+                    };
+                    
+                    let mut health_spans = vec![
+                        Span::raw("  "),
+                        Span::styled("├─ ", Typography::tree()),
+                    ];
+                    health_spans.extend(StatusIcons::create_status_spans(pool.health_status.clone(), &health_text));
+                    lines.push(Line::from(health_spans));
                 }
-                if let Some(wear) = drive.wear_percent {
-                    drive_info.push(format!("W: {:.0}%", wear));
-                }
-                let drive_text = if drive_info.is_empty() {
-                    drive.name.clone()
-                } else {
-                    format!("{} {}", drive.name, drive_info.join(" • "))
-                };
-
-                let mut drive_spans = vec![
-                    Span::raw("  "),
-                    Span::styled(tree_symbol, Typography::tree()),
-                    Span::raw(" "),
-                ];
-                drive_spans.extend(StatusIcons::create_status_spans(drive.status.clone(), &drive_text));
-                lines.push(Line::from(drive_spans));
             }
 
-            // Usage line
-            if pool.usage_percent.is_some() {
-                let tree_symbol = "└─";
-                let mut usage_spans = vec![
-                    Span::raw("  "),
-                    Span::styled(tree_symbol, Typography::tree()),
-                    Span::raw(" "),
-                ];
-                usage_spans.extend(StatusIcons::create_status_spans(pool.status.clone(), &usage_text));
-                lines.push(Line::from(usage_spans));
+            // Total usage line (always show for pools)
+            let usage_text = match (pool.usage_percent, pool.used_gb, pool.total_gb) {
+                (Some(pct), Some(used), Some(total)) => {
+                    format!("Total: {:.0}% {:.1}GB/{:.1}GB", pct, used, total)
+                }
+                _ => "Total: —% —GB/—GB".to_string(),
+            };
+            
+            let has_drives = !pool.drives.is_empty();
+            let has_filesystems = !pool.filesystems.is_empty();
+            let has_children = has_drives || has_filesystems;
+            let tree_symbol = if has_children { "├─" } else { "└─" };
+            let mut usage_spans = vec![
+                Span::raw("  "),
+                Span::styled(tree_symbol, Typography::tree()),
+                Span::raw(" "),
+            ];
+            usage_spans.extend(StatusIcons::create_status_spans(pool.status.clone(), &usage_text));
+            lines.push(Line::from(usage_spans));
+
+            // Drive lines with enhanced grouping
+            if pool.pool_type != "single" && pool.drives.len() > 1 {
+                // Group drives by type for mergerfs pools
+                let (data_drives, parity_drives): (Vec<_>, Vec<_>) = pool.drives.iter().enumerate()
+                    .partition(|(_, drive)| {
+                        // Simple heuristic: drives with 'parity' in name or sdc (common parity drive)
+                        !drive.name.to_lowercase().contains("parity") && drive.name != "sdc"
+                    });
+
+                // Show data drives
+                if !data_drives.is_empty() && pool.pool_type.contains("mergerfs") {
+                    lines.push(Line::from(vec![
+                        Span::raw("  "),
+                        Span::styled("├─ ", Typography::tree()),
+                        Span::styled("Data Disks:", Typography::secondary()),
+                    ]));
+                    
+                    for (i, (_, drive)) in data_drives.iter().enumerate() {
+                        let is_last = i == data_drives.len() - 1;
+                        if is_last && parity_drives.is_empty() {
+                            self.render_drive_line(&mut lines, drive, "│  └─");
+                        } else {
+                            self.render_drive_line(&mut lines, drive, "│  ├─");
+                        }
+                    }
+                }
+
+                // Show parity drives
+                if !parity_drives.is_empty() && pool.pool_type.contains("mergerfs") {
+                    lines.push(Line::from(vec![
+                        Span::raw("  "),
+                        Span::styled("└─ ", Typography::tree()),
+                        Span::styled("Parity:", Typography::secondary()),
+                    ]));
+                    
+                    for (i, (_, drive)) in parity_drives.iter().enumerate() {
+                        let is_last = i == parity_drives.len() - 1;
+                        if is_last {
+                            self.render_drive_line(&mut lines, drive, "   └─");
+                        } else {
+                            self.render_drive_line(&mut lines, drive, "   ├─");
+                        }
+                    }
+                } else {
+                    // Regular drive listing for non-mergerfs pools
+                    for (i, drive) in pool.drives.iter().enumerate() {
+                        let is_last = i == pool.drives.len() - 1;
+                        let tree_symbol = if is_last { "└─" } else { "├─" };
+                        self.render_drive_line(&mut lines, drive, tree_symbol);
+                    }
+                }
+            } else if pool.pool_type.starts_with("drive (") {
+                // Physical drive pools: show drive info + filesystem children
+                // First show drive information
+                for drive in &pool.drives {
+                    let mut drive_info = Vec::new();
+                    if let Some(temp) = drive.temperature {
+                        drive_info.push(format!("T: {:.0}°C", temp));
+                    }
+                    if let Some(wear) = drive.wear_percent {
+                        drive_info.push(format!("W: {:.0}%", wear));
+                    }
+                    let drive_text = if drive_info.is_empty() {
+                        format!("Drive: {}", drive.name)
+                    } else {
+                        format!("Drive: {}", drive_info.join(" "))
+                    };
+
+                    let has_filesystems = !pool.filesystems.is_empty();
+                    let tree_symbol = if has_filesystems { "├─" } else { "└─" };
+                    let mut drive_spans = vec![
+                        Span::raw("  "),
+                        Span::styled(tree_symbol, Typography::tree()),
+                        Span::raw(" "),
+                    ];
+                    drive_spans.extend(StatusIcons::create_status_spans(drive.status.clone(), &drive_text));
+                    lines.push(Line::from(drive_spans));
+                }
+
+                // Then show filesystem children
+                for (i, filesystem) in pool.filesystems.iter().enumerate() {
+                    let is_last = i == pool.filesystems.len() - 1;
+                    let tree_symbol = if is_last { "└─" } else { "├─" };
+                    
+                    let fs_text = match (filesystem.usage_percent, filesystem.used_gb, filesystem.total_gb) {
+                        (Some(pct), Some(used), Some(total)) => {
+                            format!("{}: {:.0}% {:.1}GB/{:.1}GB", filesystem.mount_point, pct, used, total)
+                        }
+                        (Some(pct), _, Some(total)) => {
+                            format!("{}: {:.0}% —GB/{:.1}GB", filesystem.mount_point, pct, total)
+                        }
+                        (Some(pct), _, _) => {
+                            format!("{}: {:.0}% —GB/—GB", filesystem.mount_point, pct)
+                        }
+                        (_, Some(used), Some(total)) => {
+                            format!("{}: —% {:.1}GB/{:.1}GB", filesystem.mount_point, used, total)
+                        }
+                        _ => format!("{}: —% —GB/—GB", filesystem.mount_point),
+                    };
+
+                    let mut fs_spans = vec![
+                        Span::raw("  "),
+                        Span::styled(tree_symbol, Typography::tree()),
+                        Span::raw(" "),
+                    ];
+                    fs_spans.extend(StatusIcons::create_status_spans(filesystem.status.clone(), &fs_text));
+                    lines.push(Line::from(fs_spans));
+                }
+            } else {
+                // Single drive or simple pools
+                for (i, drive) in pool.drives.iter().enumerate() {
+                    let is_last = i == pool.drives.len() - 1;
+                    let tree_symbol = if is_last { "└─" } else { "├─" };
+                    self.render_drive_line(&mut lines, drive, tree_symbol);
+                }
             }
         }
 
         lines
     }
+
+    /// Helper to render a single drive line
+    fn render_drive_line<'a>(&self, lines: &mut Vec<Line<'a>>, drive: &StorageDrive, tree_symbol: &'a str) {
+        let mut drive_info = Vec::new();
+        if let Some(temp) = drive.temperature {
+            drive_info.push(format!("T: {:.0}°C", temp));
+        }
+        if let Some(wear) = drive.wear_percent {
+            drive_info.push(format!("W: {:.0}%", wear));
+        }
+        let drive_text = if drive_info.is_empty() {
+            drive.name.clone()
+        } else {
+            format!("{} {}", drive.name, drive_info.join(" • "))
+        };
+
+        let mut drive_spans = vec![
+            Span::raw("  "),
+            Span::styled(tree_symbol, Typography::tree()),
+            Span::raw(" "),
+        ];
+        drive_spans.extend(StatusIcons::create_status_spans(drive.status.clone(), &drive_text));
+        lines.push(Line::from(drive_spans));
+    }
 }
 
 impl Widget for SystemWidget {

shared/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "cm-dashboard-shared"
-version = "0.1.97"
+version = "0.1.110"
 edition = "2021"
 
 [dependencies]

shared/src/metrics.rs

@@ -82,13 +82,13 @@ impl MetricValue {
 /// Health status for metrics
 #[derive(Debug, Clone, Copy, Serialize, Deserialize, PartialEq, Eq, PartialOrd, Ord)]
 pub enum Status {
-    Inactive, // Lowest priority - treated as good
-    Ok,       // Second lowest - also good
-    Unknown,
-    Offline,
-    Pending,
-    Warning,
-    Critical,
+    Inactive, // Lowest priority
+    Unknown,  // 
+    Offline,  // 
+    Pending,  // 
+    Ok,       // 5th place - good status has higher priority than unknown states
+    Warning,  // 
+    Critical, // Highest priority
 }
 
 impl Status {