This commit is contained in:
weisd
2025-06-10 18:51:06 +08:00
parent 0e575ef2be
commit 3338f3236f
+7 -7
View File
@@ -1,6 +1,7 @@
#![allow(unused_variables)] #![allow(unused_variables)]
#![allow(dead_code)] #![allow(dead_code)]
// use error::Error; // use error::Error;
use crate::StorageAPI;
use crate::bucket::metadata_sys::get_replication_config; use crate::bucket::metadata_sys::get_replication_config;
use crate::bucket::versioning_sys::BucketVersioningSys; use crate::bucket::versioning_sys::BucketVersioningSys;
use crate::error::Error; use crate::error::Error;
@@ -11,26 +12,25 @@ use crate::store_api::ObjectIO;
use crate::store_api::ObjectInfo; use crate::store_api::ObjectInfo;
use crate::store_api::ObjectOptions; use crate::store_api::ObjectOptions;
use crate::store_api::ObjectToDelete; use crate::store_api::ObjectToDelete;
use crate::StorageAPI; use aws_sdk_s3::Client as S3Client;
use aws_sdk_s3::Config;
use aws_sdk_s3::config::BehaviorVersion; use aws_sdk_s3::config::BehaviorVersion;
use aws_sdk_s3::config::Credentials; use aws_sdk_s3::config::Credentials;
use aws_sdk_s3::config::Region; use aws_sdk_s3::config::Region;
use aws_sdk_s3::Client as S3Client;
use aws_sdk_s3::Config;
use bytes::Bytes; use bytes::Bytes;
use chrono::DateTime; use chrono::DateTime;
use chrono::Duration; use chrono::Duration;
use chrono::Utc; use chrono::Utc;
use futures::stream::FuturesUnordered;
use futures::StreamExt; use futures::StreamExt;
use futures::stream::FuturesUnordered;
use http::HeaderMap; use http::HeaderMap;
use http::Method; use http::Method;
use lazy_static::lazy_static; use lazy_static::lazy_static;
// use std::time::SystemTime; // use std::time::SystemTime;
use once_cell::sync::Lazy; use once_cell::sync::Lazy;
use regex::Regex; use regex::Regex;
use rustfs_rsc::provider::StaticProvider;
use rustfs_rsc::Minio; use rustfs_rsc::Minio;
use rustfs_rsc::provider::StaticProvider;
use s3s::dto::DeleteMarkerReplicationStatus; use s3s::dto::DeleteMarkerReplicationStatus;
use s3s::dto::DeleteReplicationStatus; use s3s::dto::DeleteReplicationStatus;
use s3s::dto::ExistingObjectReplicationStatus; use s3s::dto::ExistingObjectReplicationStatus;
@@ -42,14 +42,14 @@ use std::collections::HashMap;
use std::collections::HashSet; use std::collections::HashSet;
use std::fmt; use std::fmt;
use std::iter::Iterator; use std::iter::Iterator;
use std::sync::Arc;
use std::sync::atomic::AtomicI32; use std::sync::atomic::AtomicI32;
use std::sync::atomic::Ordering; use std::sync::atomic::Ordering;
use std::sync::Arc;
use std::vec; use std::vec;
use time::OffsetDateTime; use time::OffsetDateTime;
use tokio::sync::mpsc::{Receiver, Sender};
use tokio::sync::Mutex; use tokio::sync::Mutex;
use tokio::sync::RwLock; use tokio::sync::RwLock;
use tokio::sync::mpsc::{Receiver, Sender};
use tokio::task; use tokio::task;
use tracing::{debug, error, info, warn}; use tracing::{debug, error, info, warn};
use uuid::Uuid; use uuid::Uuid;