fix fmt

Signed-off-by: junxiang Mu <1948535941@qq.com>

crates/ahm/src/heal/manager.rs

@@ -18,8 +18,8 @@ use crate::heal::{
     storage::HealStorageAPI,
     task::{HealOptions, HealPriority, HealRequest, HealTask, HealTaskStatus, HealType},
 };
-use rustfs_ecstore::disk::error::DiskError;
 use rustfs_ecstore::disk::DiskAPI;
+use rustfs_ecstore::disk::error::DiskError;
 use rustfs_ecstore::global::GLOBAL_LOCAL_DISK_MAP;
 use std::{
     collections::{HashMap, VecDeque},

crates/ahm/src/heal/resume.rs

@@ -13,7 +13,7 @@
 // limitations under the License.
 
 use crate::error::{Error, Result};
-use rustfs_ecstore::disk::{DiskAPI, DiskStore, BUCKET_META_PREFIX, RUSTFS_META_BUCKET};
+use rustfs_ecstore::disk::{BUCKET_META_PREFIX, DiskAPI, DiskStore, RUSTFS_META_BUCKET};
 use serde::{Deserialize, Serialize};
 use std::path::Path;
 use std::sync::Arc;
@@ -618,7 +618,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_get_resumable_tasks_integration() {
-        use rustfs_ecstore::disk::{endpoint::Endpoint, new_disk, DiskOption};
+        use rustfs_ecstore::disk::{DiskOption, endpoint::Endpoint, new_disk};
         use tempfile::TempDir;
 
         // Create a temporary directory for testing

crates/ahm/src/heal/storage.rs

@@ -16,7 +16,7 @@ use crate::error::{Error, Result};
 use async_trait::async_trait;
 use rustfs_common::heal_channel::{HealOpts, HealScanMode};
 use rustfs_ecstore::{
-    disk::{endpoint::Endpoint, DiskStore},
+    disk::{DiskStore, endpoint::Endpoint},
     store::ECStore,
     store_api::{BucketInfo, ObjectIO, StorageAPI},
 };

crates/ahm/src/lib.rs

@@ -21,7 +21,7 @@ pub mod heal;
 pub mod scanner;
 
 pub use error::{Error, Result};
-pub use heal::{channel::HealChannelProcessor, HealManager, HealOptions, HealPriority, HealRequest, HealType};
+pub use heal::{HealManager, HealOptions, HealPriority, HealRequest, HealType, channel::HealChannelProcessor};
 pub use scanner::Scanner;
 
 // Global cancellation token for AHM services (scanner and other background tasks)

crates/ahm/src/scanner/data_scanner.rs

@@ -22,7 +22,7 @@ use ecstore::{
     disk::{DiskAPI, DiskStore, WalkDirOptions},
     set_disk::SetDisks,
 };
-use rustfs_ecstore::{self as ecstore, data_usage::store_data_usage_in_backend, StorageAPI};
+use rustfs_ecstore::{self as ecstore, StorageAPI, data_usage::store_data_usage_in_backend};
 use rustfs_filemeta::MetacacheReader;
 use tokio::sync::{Mutex, RwLock};
 use tokio_util::sync::CancellationToken;
@@ -31,12 +31,13 @@ use tracing::{debug, error, info, warn};
 use super::metrics::{BucketMetrics, DiskMetrics, MetricsCollector, ScannerMetrics};
 use crate::heal::HealManager;
 use crate::{
+    HealRequest,
     error::{Error, Result},
-    get_ahm_services_cancel_token, HealRequest,
+    get_ahm_services_cancel_token,
 };
 use rustfs_common::{
     data_usage::DataUsageInfo,
-    metrics::{globalMetrics, Metric, Metrics},
+    metrics::{Metric, Metrics, globalMetrics},
 };
 
 use rustfs_ecstore::disk::RUSTFS_META_BUCKET;
@@ -1393,8 +1394,8 @@ mod tests {
     use rustfs_ecstore::endpoints::{EndpointServerPools, Endpoints, PoolEndpoints};
     use rustfs_ecstore::store::ECStore;
     use rustfs_ecstore::{
-        store_api::{MakeBucketOptions, ObjectIO, PutObjReader},
         StorageAPI,
+        store_api::{MakeBucketOptions, ObjectIO, PutObjReader},
     };
     use serial_test::serial;
     use std::fs;