fix: Apply cargo fmt to rate_limit module

Fix formatting issues in rate_limit module files:
- config.rs
- dashboard.rs
- manager.rs
- mod.rs
- quota.rs
- store.rs

This fixes the cargo fmt check failure.

Author: Auto Merge Bot

orchestrator/src/rate_limit/config.rs

@@ -188,7 +188,10 @@ mod tests {
     #[test]
     fn test_quota_reset_duration() {
         let config = RateLimitConfig::default();
-        assert_eq!(config.quota_reset_duration(), Duration::from_secs(24 * 3600));
+        assert_eq!(
+            config.quota_reset_duration(),
+            Duration::from_secs(24 * 3600)
+        );
     }
 
     #[test]
@@ -198,4 +201,4 @@ mod tests {
         let parsed: RateLimitConfig = serde_json::from_str(&json).unwrap();
         assert_eq!(config.default_api_limit, parsed.default_api_limit);
     }
-}
+}

orchestrator/src/rate_limit/dashboard.rs

@@ -110,15 +110,9 @@ impl DashboardBuilder {
                 let entity_id = parts[1].to_string();
 
                 if entity_type_str == "User" {
-                    user_stats_map
-                        .entry(entity_id)
-                        .or_default()
-                        .push(stat);
+                    user_stats_map.entry(entity_id).or_default().push(stat);
                 } else if entity_type_str == "Agent" {
-                    agent_stats_map
-                        .entry(entity_id)
-                        .or_default()
-                        .push(stat);
+                    agent_stats_map.entry(entity_id).or_default().push(stat);
                 }
             }
         }
@@ -157,11 +151,7 @@ impl DashboardBuilder {
         let summary = self.build_summary(&user_stats, &agent_stats, &history);
 
         // Get recent history (last 100 records)
-        let recent_history: Vec<UsageRecord> = history
-            .into_iter()
-            .rev()
-            .take(100)
-            .collect();
+        let recent_history: Vec<UsageRecord> = history.into_iter().rev().take(100).collect();
 
         DashboardData {
             timestamp: chrono::Utc::now(),
@@ -218,10 +208,7 @@ impl DashboardBuilder {
             }
         }
 
-        let rate_limited_count = history
-            .iter()
-            .filter(|r| !r.success)
-            .count() as u64;
+        let rate_limited_count = history.iter().filter(|r| !r.success).count() as u64;
 
         let avg_utilization_percent = if quota_count > 0 {
             total_utilization / quota_count as f64
@@ -435,4 +422,4 @@ mod tests {
         assert_eq!(parsed.entity_id, "user-123");
         assert_eq!(parsed.entity_type, EntityType::User);
     }
-}
+}

orchestrator/src/rate_limit/manager.rs

@@ -479,4 +479,4 @@ mod tests {
         assert_eq!(denied.retry_after_secs, Some(60));
         assert_eq!(denied.reason, Some("Rate limit exceeded".to_string()));
     }
-}
+}

orchestrator/src/rate_limit/mod.rs

@@ -28,13 +28,13 @@
 //! ```
 
 pub mod config;
+pub mod dashboard;
 pub mod manager;
 pub mod quota;
 pub mod store;
-pub mod dashboard;
 
 pub use config::RateLimitConfig;
+pub use dashboard::DashboardData;
 pub use manager::RateLimitManager;
 pub use quota::{Quota, QuotaType, UsageStats};
 pub use store::QuotaStore;
-pub use dashboard::DashboardData;

orchestrator/src/rate_limit/quota.rs

@@ -32,8 +32,8 @@ impl QuotaType {
     /// Get the refill rate (tokens per second)
     pub fn default_refill_rate(&self) -> f64 {
         match self {
-            QuotaType::ApiCalls => 100.0 / 60.0,      // 100 per minute
-            QuotaType::VmSpawn => 10.0 / 3600.0,      // 10 per hour
+            QuotaType::ApiCalls => 100.0 / 60.0,         // 100 per minute
+            QuotaType::VmSpawn => 10.0 / 3600.0,         // 10 per hour
             QuotaType::ApprovalRequest => 50.0 / 3600.0, // 50 per hour
         }
     }
@@ -450,4 +450,4 @@ mod tests {
         // Should need 2 seconds to get 20 tokens at 10 tokens/sec
         assert!(time.as_secs_f64() >= 1.9 && time.as_secs_f64() <= 2.1);
     }
-}
+}

orchestrator/src/rate_limit/store.rs

@@ -120,7 +120,10 @@ impl QuotaStore {
         let mut quotas = self.quotas.write().await;
 
         if !quotas.contains_key(key) {
-            let quota_id = format!("{:?}-{}-{:?}", key.entity_type, key.entity_id, key.quota_type);
+            let quota_id = format!(
+                "{:?}-{}-{:?}",
+                key.entity_type, key.entity_id, key.quota_type
+            );
             let quota = Quota::new(key.quota_type, quota_id);
             quotas.insert(key.clone(), quota);
         }
@@ -168,11 +171,7 @@ impl QuotaStore {
     /// Get usage history for a key
     pub async fn get_usage_history(&self, key: &QuotaKey) -> Vec<UsageRecord> {
         let history = self.usage_history.read().await;
-        history
-            .iter()
-            .filter(|r| &r.key == key)
-            .cloned()
-            .collect()
+        history.iter().filter(|r| &r.key == key).cloned().collect()
     }
 
     /// Get all usage history
@@ -335,4 +334,4 @@ mod tests {
         assert_eq!(key.entity_type, EntityType::Agent);
         assert_eq!(key.quota_type, QuotaType::VmSpawn);
     }
-}
+}