feat(enterprise): implement comprehensive stats and metrics commands (#240)

* feat(enterprise): implement comprehensive stats and metrics commands

Implements issue #156 - comprehensive statistics and metrics collection commands
for Redis Enterprise API.

## Commands Added

### Database Statistics
- `redisctl enterprise stats database <id>` - Get database statistics
- `redisctl enterprise stats database-shards <id>` - Get database shard statistics
- `redisctl enterprise stats database-metrics <id> --interval 1h` - Get database metrics over time

### Node Statistics
- `redisctl enterprise stats node <id>` - Get node statistics
- `redisctl enterprise stats node-metrics <id> --interval 1h` - Get node metrics over time

### Cluster Statistics
- `redisctl enterprise stats cluster` - Get cluster-wide statistics
- `redisctl enterprise stats cluster-metrics --interval 1h` - Get cluster metrics over time

### Listener & Export
- `redisctl enterprise stats listener` - Get listener statistics
- `redisctl enterprise stats export --format json --interval 1h` - Export statistics in various formats

## Implementation Notes
- Uses redis-enterprise StatsHandler for all operations
- Supports various time intervals (1m, 5m, 1h, 1d)
- Handles large datasets efficiently with proper JSON serialization
- Consistent error handling and output formatting
- Standard JMESPath filtering and output format support

## Testing
- Compiles cleanly with proper type safety
- Follows existing enterprise command patterns
- Uses established connection management and output utilities

This provides essential monitoring capabilities for Redis Enterprise deployments,
complementing the existing database and node management commands.

* chore: add #[allow(dead_code)] to suppress false positive warnings

These functions are used by the binary but appear unused from the library's perspective.

* fix(enterprise): correct LastStatsResponse structure to match actual API

The API returns stats fields directly with stime/etime, not wrapped in a
metrics object. This fixes the 'error decoding response body' issue when
running stats commands.

* fix(enterprise): fix stats test data format

The LastStatsResponse struct uses serde(flatten) to include metrics
at the top level, not in a nested 'metrics' field. Updated test data
to match the actual API response format.

Author: joshrotenberg

crates/redis-enterprise/src/stats.rs

@@ -93,12 +93,14 @@ pub struct StatsInterval {
 }
 
 /// Last stats response for single resource
+/// Response for last stats endpoint - the API returns metrics directly
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct LastStatsResponse {
-    pub time: String,
-    pub metrics: Value,
+    pub stime: Option<String>,
+    pub etime: Option<String>,
+    pub interval: Option<String>,
     #[serde(flatten)]
-    pub extra: Value,
+    pub metrics: Value, // All other fields are metrics
 }
 
 /// Aggregated stats response for multiple resources

crates/redis-enterprise/tests/stats_tests.rs

@@ -101,41 +101,41 @@ fn test_shard_stats() -> serde_json::Value {
 
 fn test_cluster_last_stats() -> serde_json::Value {
     json!({
-        "time": "2023-01-01T12:02:00Z",
-        "metrics": {
-            "cpu_usage": 28.3,
-            "memory_usage": 77.5,
-            "network_in": 1150000,
-            "network_out": 2300000,
-            "total_req": 158000
-        }
+        "stime": "2023-01-01T12:00:00Z",
+        "etime": "2023-01-01T12:02:00Z",
+        "interval": "2m",
+        "cpu_usage": 28.3,
+        "memory_usage": 77.5,
+        "network_in": 1150000,
+        "network_out": 2300000,
+        "total_req": 158000
     })
 }
 
 fn test_node_last_stats() -> serde_json::Value {
     json!({
-        "time": "2023-01-01T12:02:00Z",
-        "metrics": {
-            "cpu_user": 16.2,
-            "cpu_system": 5.8,
-            "cpu_idle": 78.0,
-            "free_memory": 4194304000u64,
-            "network_bytes_in": 520000,
-            "network_bytes_out": 1040000
-        }
+        "stime": "2023-01-01T12:00:00Z",
+        "etime": "2023-01-01T12:02:00Z",
+        "interval": "2m",
+        "cpu_user": 16.2,
+        "cpu_system": 5.8,
+        "cpu_idle": 78.0,
+        "free_memory": 4194304000u64,
+        "network_bytes_in": 520000,
+        "network_bytes_out": 1040000
     })
 }
 
 fn test_database_last_stats() -> serde_json::Value {
     json!({
-        "time": "2023-01-01T12:02:00Z",
-        "metrics": {
-            "used_memory": 1100000,
-            "total_req": 5200,
-            "ops_per_sec": 105.2,
-            "hits": 4680,
-            "misses": 520
-        }
+        "stime": "2023-01-01T12:00:00Z",
+        "etime": "2023-01-01T12:02:00Z",
+        "interval": "2m",
+        "used_memory": 1100000,
+        "total_req": 5200,
+        "ops_per_sec": 105.2,
+        "hits": 4680,
+        "misses": 520
     })
 }
 

crates/redisctl/src/cli.rs

@@ -996,6 +996,10 @@ pub enum EnterpriseCommands {
     /// Module management operations
     #[command(subcommand)]
     Module(crate::commands::enterprise::module::ModuleCommands),
+
+    /// Statistics and metrics operations
+    #[command(subcommand)]
+    Stats(EnterpriseStatsCommands),
 }
 
 // Placeholder command structures - will be expanded in later PRs
@@ -2549,3 +2553,65 @@ pub enum EnterpriseCrdbCommands {
         data: String,
     },
 }
+
+#[derive(Subcommand, Debug, Clone)]
+pub enum EnterpriseStatsCommands {
+    /// Get database statistics
+    Database {
+        /// Database ID
+        id: u32,
+    },
+
+    /// Get database shard statistics
+    DatabaseShards {
+        /// Database ID
+        id: u32,
+    },
+
+    /// Get database metrics over time
+    DatabaseMetrics {
+        /// Database ID
+        id: u32,
+        /// Time interval (1m, 5m, 1h, 1d)
+        #[arg(long, default_value = "1h")]
+        interval: String,
+    },
+
+    /// Get node statistics
+    Node {
+        /// Node ID
+        id: u32,
+    },
+
+    /// Get node metrics over time
+    NodeMetrics {
+        /// Node ID
+        id: u32,
+        /// Time interval (1m, 5m, 1h, 1d)
+        #[arg(long, default_value = "1h")]
+        interval: String,
+    },
+
+    /// Get cluster-wide statistics
+    Cluster,
+
+    /// Get cluster metrics over time
+    ClusterMetrics {
+        /// Time interval (1m, 5m, 1h, 1d)
+        #[arg(long, default_value = "1h")]
+        interval: String,
+    },
+
+    /// Get listener statistics
+    Listener,
+
+    /// Export statistics in various formats
+    Export {
+        /// Export format (json, prometheus, csv)
+        #[arg(long, default_value = "json")]
+        format: String,
+        /// Time interval for time-series data (1m, 5m, 1h, 1d)
+        #[arg(long)]
+        interval: Option<String>,
+    },
+}

crates/redisctl/src/commands/enterprise/mod.rs

@@ -14,4 +14,5 @@ pub mod node;
 pub mod node_impl;
 pub mod rbac;
 pub mod rbac_impl;
+pub mod stats;
 pub mod utils;