You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@opendal.apache.org by xu...@apache.org on 2024/03/13 09:49:29 UTC
(opendal) 03/04: Fix check
This is an automated email from the ASF dual-hosted git repository.
xuanwo pushed a commit to branch refactor-list
in repository https://gitbox.apache.org/repos/asf/opendal.git
commit 00d741c949da98e9b061e2defd738245a2193afb
Author: Xuanwo <gi...@xuanwo.io>
AuthorDate: Wed Mar 13 17:46:13 2024 +0800
Fix check
Signed-off-by: Xuanwo <gi...@xuanwo.io>
---
core/src/layers/minitrace.rs | 2 +-
core/src/layers/oteltrace.rs | 2 +-
core/src/layers/retry.rs | 6 +++---
core/src/layers/timeout.rs | 4 ++--
core/src/layers/tracing.rs | 2 +-
core/src/services/alluxio/lister.rs | 2 +-
core/src/services/azblob/lister.rs | 2 +-
core/src/services/azdls/lister.rs | 2 +-
core/src/services/azfile/lister.rs | 2 +-
core/src/services/b2/lister.rs | 2 +-
core/src/services/chainsafe/lister.rs | 2 +-
core/src/services/cos/lister.rs | 2 +-
core/src/services/dbfs/lister.rs | 2 +-
core/src/services/fs/lister.rs | 16 ++++++++--------
core/src/services/ftp/lister.rs | 6 +++---
core/src/services/gcs/lister.rs | 2 +-
core/src/services/gdrive/lister.rs | 1 -
core/src/services/github/lister.rs | 2 --
core/src/services/hdfs/lister.rs | 10 +++++-----
core/src/services/hdfs_native/lister.rs | 6 +++---
core/src/services/huggingface/lister.rs | 2 +-
core/src/services/ipmfs/lister.rs | 2 +-
core/src/services/koofr/lister.rs | 2 +-
core/src/services/obs/lister.rs | 2 +-
core/src/services/onedrive/lister.rs | 2 +-
core/src/services/oss/lister.rs | 2 +-
core/src/services/pcloud/lister.rs | 2 +-
core/src/services/s3/lister.rs | 2 +-
core/src/services/seafile/lister.rs | 2 +-
core/src/services/sftp/lister.rs | 10 +++++-----
core/src/services/swift/lister.rs | 2 +-
core/src/services/upyun/lister.rs | 2 +-
core/src/services/vercel_blob/lister.rs | 2 +-
core/src/services/webdav/lister.rs | 2 +-
core/src/services/webhdfs/lister.rs | 1 -
core/src/services/yandex_disk/lister.rs | 2 +-
36 files changed, 55 insertions(+), 59 deletions(-)
diff --git a/core/src/layers/minitrace.rs b/core/src/layers/minitrace.rs
index 9e525f7bd9..2f3962b48c 100644
--- a/core/src/layers/minitrace.rs
+++ b/core/src/layers/minitrace.rs
@@ -16,7 +16,7 @@
// under the License.
use std::fmt::Debug;
-use std::future::Future;
+
use std::io;
use std::task::Context;
use std::task::Poll;
diff --git a/core/src/layers/oteltrace.rs b/core/src/layers/oteltrace.rs
index 2aa70810f8..abd3074fb2 100644
--- a/core/src/layers/oteltrace.rs
+++ b/core/src/layers/oteltrace.rs
@@ -15,7 +15,7 @@
// specific language governing permissions and limitations
// under the License.
-use std::future::Future;
+
use std::io;
use std::task::Context;
use std::task::Poll;
diff --git a/core/src/layers/retry.rs b/core/src/layers/retry.rs
index b63b55e396..e963a9cca4 100644
--- a/core/src/layers/retry.rs
+++ b/core/src/layers/retry.rs
@@ -17,7 +17,7 @@
use std::fmt::Debug;
use std::fmt::Formatter;
-use std::future::Future;
+
use std::io;
use std::pin::Pin;
use std::sync::Arc;
@@ -1013,8 +1013,8 @@ mod tests {
use std::io;
use std::sync::Arc;
use std::sync::Mutex;
- use std::task::Context;
- use std::task::Poll;
+
+
use async_trait::async_trait;
use bytes::Bytes;
diff --git a/core/src/layers/timeout.rs b/core/src/layers/timeout.rs
index ef4a4936bf..c6074c9d50 100644
--- a/core/src/layers/timeout.rs
+++ b/core/src/layers/timeout.rs
@@ -371,8 +371,8 @@ mod tests {
use std::future::{pending, Future};
use std::io::SeekFrom;
use std::sync::Arc;
- use std::task::Context;
- use std::task::Poll;
+
+
use std::time::Duration;
use async_trait::async_trait;
diff --git a/core/src/layers/tracing.rs b/core/src/layers/tracing.rs
index e0a3b8a541..e172e78db7 100644
--- a/core/src/layers/tracing.rs
+++ b/core/src/layers/tracing.rs
@@ -16,7 +16,7 @@
// under the License.
use std::fmt::Debug;
-use std::future::Future;
+
use std::io;
use std::task::Context;
use std::task::Poll;
diff --git a/core/src/services/alluxio/lister.rs b/core/src/services/alluxio/lister.rs
index 845c0053ac..9cb073b8e2 100644
--- a/core/src/services/alluxio/lister.rs
+++ b/core/src/services/alluxio/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use super::core::AlluxioCore;
use crate::raw::oio::Entry;
diff --git a/core/src/services/azblob/lister.rs b/core/src/services/azblob/lister.rs
index 4ea2cabda2..e51663b460 100644
--- a/core/src/services/azblob/lister.rs
+++ b/core/src/services/azblob/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use bytes::Buf;
use quick_xml::de;
diff --git a/core/src/services/azdls/lister.rs b/core/src/services/azdls/lister.rs
index 65171d57aa..b4b9d55817 100644
--- a/core/src/services/azdls/lister.rs
+++ b/core/src/services/azdls/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use serde::Deserialize;
use serde_json::de;
diff --git a/core/src/services/azfile/lister.rs b/core/src/services/azfile/lister.rs
index ae222e3339..9a12716466 100644
--- a/core/src/services/azfile/lister.rs
+++ b/core/src/services/azfile/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use http::StatusCode;
use quick_xml::de::from_str;
use serde::Deserialize;
diff --git a/core/src/services/b2/lister.rs b/core/src/services/b2/lister.rs
index f404e38120..50e29a6fb0 100644
--- a/core/src/services/b2/lister.rs
+++ b/core/src/services/b2/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use bytes::Buf;
use super::core::parse_file_info;
diff --git a/core/src/services/chainsafe/lister.rs b/core/src/services/chainsafe/lister.rs
index e0ac35c8d8..182e374ab9 100644
--- a/core/src/services/chainsafe/lister.rs
+++ b/core/src/services/chainsafe/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use http::StatusCode;
use super::core::parse_info;
diff --git a/core/src/services/cos/lister.rs b/core/src/services/cos/lister.rs
index d46db1a100..ed23bfb3a9 100644
--- a/core/src/services/cos/lister.rs
+++ b/core/src/services/cos/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use bytes::Buf;
use quick_xml::de;
diff --git a/core/src/services/dbfs/lister.rs b/core/src/services/dbfs/lister.rs
index 11d36c1ae2..df122679c0 100644
--- a/core/src/services/dbfs/lister.rs
+++ b/core/src/services/dbfs/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use http::StatusCode;
use serde::Deserialize;
diff --git a/core/src/services/fs/lister.rs b/core/src/services/fs/lister.rs
index d99414ea69..c015642e39 100644
--- a/core/src/services/fs/lister.rs
+++ b/core/src/services/fs/lister.rs
@@ -15,18 +15,18 @@
// specific language governing permissions and limitations
// under the License.
-use std::fs::FileType;
-use std::future::Future;
+
+
use std::path::Path;
use std::path::PathBuf;
-use std::task::ready;
-use std::task::Context;
-use std::task::Poll;
-use futures::future::BoxFuture;
-use futures::FutureExt;
-use crate::raw::oio::Entry;
+
+
+
+
+
+
use crate::raw::*;
use crate::EntryMode;
use crate::Metadata;
diff --git a/core/src/services/ftp/lister.rs b/core/src/services/ftp/lister.rs
index 023dbd8a06..10eac4f3cd 100644
--- a/core/src/services/ftp/lister.rs
+++ b/core/src/services/ftp/lister.rs
@@ -15,11 +15,11 @@
// specific language governing permissions and limitations
// under the License.
-use std::future::Future;
+
use std::str;
use std::str::FromStr;
-use std::task::Context;
-use std::task::Poll;
+
+
use std::vec::IntoIter;
use suppaftp::list::File;
diff --git a/core/src/services/gcs/lister.rs b/core/src/services/gcs/lister.rs
index d5d6d0a891..7527f36f65 100644
--- a/core/src/services/gcs/lister.rs
+++ b/core/src/services/gcs/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use serde_json;
use super::core::*;
diff --git a/core/src/services/gdrive/lister.rs b/core/src/services/gdrive/lister.rs
index b61bf16b77..34df9073f3 100644
--- a/core/src/services/gdrive/lister.rs
+++ b/core/src/services/gdrive/lister.rs
@@ -17,7 +17,6 @@
use std::sync::Arc;
-use async_trait::async_trait;
use http::StatusCode;
use super::core::GdriveCore;
diff --git a/core/src/services/github/lister.rs b/core/src/services/github/lister.rs
index c26a7eb383..654f3cbb78 100644
--- a/core/src/services/github/lister.rs
+++ b/core/src/services/github/lister.rs
@@ -17,8 +17,6 @@
use std::sync::Arc;
-use async_trait::async_trait;
-
use super::core::GithubCore;
use crate::raw::oio::Entry;
use crate::raw::*;
diff --git a/core/src/services/hdfs/lister.rs b/core/src/services/hdfs/lister.rs
index a14e305300..e1fd7b27ef 100644
--- a/core/src/services/hdfs/lister.rs
+++ b/core/src/services/hdfs/lister.rs
@@ -15,13 +15,13 @@
// specific language governing permissions and limitations
// under the License.
-use std::future::Future;
-use std::task::Context;
-use std::task::Poll;
-use async_trait::async_trait;
-use crate::raw::oio::Entry;
+
+
+
+
+
use crate::raw::*;
use crate::EntryMode;
use crate::Metadata;
diff --git a/core/src/services/hdfs_native/lister.rs b/core/src/services/hdfs_native/lister.rs
index 64f9ffa8d1..0162e5943b 100644
--- a/core/src/services/hdfs_native/lister.rs
+++ b/core/src/services/hdfs_native/lister.rs
@@ -15,10 +15,10 @@
// specific language governing permissions and limitations
// under the License.
-use std::future::Future;
+
use std::sync::Arc;
-use std::task::Context;
-use std::task::Poll;
+
+
use crate::raw::oio;
use crate::raw::oio::Entry;
diff --git a/core/src/services/huggingface/lister.rs b/core/src/services/huggingface/lister.rs
index 3ecceb8ae9..b74f1c548c 100644
--- a/core/src/services/huggingface/lister.rs
+++ b/core/src/services/huggingface/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use super::core::HuggingfaceCore;
use super::core::HuggingfaceStatus;
diff --git a/core/src/services/ipmfs/lister.rs b/core/src/services/ipmfs/lister.rs
index 0d97b0c438..cd162426d7 100644
--- a/core/src/services/ipmfs/lister.rs
+++ b/core/src/services/ipmfs/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use http::StatusCode;
use serde::Deserialize;
diff --git a/core/src/services/koofr/lister.rs b/core/src/services/koofr/lister.rs
index a206447682..a3f0bea847 100644
--- a/core/src/services/koofr/lister.rs
+++ b/core/src/services/koofr/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use super::core::KoofrCore;
use super::core::ListResponse;
diff --git a/core/src/services/obs/lister.rs b/core/src/services/obs/lister.rs
index e26c00d720..a1414ae25a 100644
--- a/core/src/services/obs/lister.rs
+++ b/core/src/services/obs/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use bytes::Buf;
use quick_xml::de;
diff --git a/core/src/services/onedrive/lister.rs b/core/src/services/onedrive/lister.rs
index a84881faa6..fe12399cb1 100644
--- a/core/src/services/onedrive/lister.rs
+++ b/core/src/services/onedrive/lister.rs
@@ -15,7 +15,7 @@
// specific language governing permissions and limitations
// under the License.
-use async_trait::async_trait;
+
use super::backend::OnedriveBackend;
use super::error::parse_error;
diff --git a/core/src/services/oss/lister.rs b/core/src/services/oss/lister.rs
index 97606e0f15..cdeef99e03 100644
--- a/core/src/services/oss/lister.rs
+++ b/core/src/services/oss/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use bytes::Buf;
use quick_xml::de;
diff --git a/core/src/services/pcloud/lister.rs b/core/src/services/pcloud/lister.rs
index 857376a1af..8b080eda4e 100644
--- a/core/src/services/pcloud/lister.rs
+++ b/core/src/services/pcloud/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use http::StatusCode;
use super::core::*;
diff --git a/core/src/services/s3/lister.rs b/core/src/services/s3/lister.rs
index dac9ceae4d..7863ba143a 100644
--- a/core/src/services/s3/lister.rs
+++ b/core/src/services/s3/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use bytes::Buf;
use quick_xml::de;
diff --git a/core/src/services/seafile/lister.rs b/core/src/services/seafile/lister.rs
index 7762597e2d..1235a01afa 100644
--- a/core/src/services/seafile/lister.rs
+++ b/core/src/services/seafile/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use http::header;
use http::Request;
use http::StatusCode;
diff --git a/core/src/services/sftp/lister.rs b/core/src/services/sftp/lister.rs
index a99c467655..5bcd0acc00 100644
--- a/core/src/services/sftp/lister.rs
+++ b/core/src/services/sftp/lister.rs
@@ -15,13 +15,13 @@
// specific language governing permissions and limitations
// under the License.
-use std::future::Future;
+
use std::pin::Pin;
-use std::task::ready;
-use std::task::Context;
-use std::task::Poll;
-use async_trait::async_trait;
+
+
+
+
use futures::StreamExt;
use openssh_sftp_client::fs::DirEntry;
use openssh_sftp_client::fs::ReadDir;
diff --git a/core/src/services/swift/lister.rs b/core/src/services/swift/lister.rs
index a7b6601157..fb4be3cd71 100644
--- a/core/src/services/swift/lister.rs
+++ b/core/src/services/swift/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use super::core::*;
use super::error::parse_error;
diff --git a/core/src/services/upyun/lister.rs b/core/src/services/upyun/lister.rs
index c093ebca00..69f9cac4a3 100644
--- a/core/src/services/upyun/lister.rs
+++ b/core/src/services/upyun/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use super::core::ListObjectsResponse;
use super::core::UpyunCore;
diff --git a/core/src/services/vercel_blob/lister.rs b/core/src/services/vercel_blob/lister.rs
index 6cad3bef4e..13aefa553a 100644
--- a/core/src/services/vercel_blob/lister.rs
+++ b/core/src/services/vercel_blob/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use super::core::parse_blob;
use super::core::VercelBlobCore;
diff --git a/core/src/services/webdav/lister.rs b/core/src/services/webdav/lister.rs
index 386e99c48b..3a169c5374 100644
--- a/core/src/services/webdav/lister.rs
+++ b/core/src/services/webdav/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use http::StatusCode;
use super::core::*;
diff --git a/core/src/services/webhdfs/lister.rs b/core/src/services/webhdfs/lister.rs
index 2215671304..cc7db189f2 100644
--- a/core/src/services/webhdfs/lister.rs
+++ b/core/src/services/webhdfs/lister.rs
@@ -15,7 +15,6 @@
// specific language governing permissions and limitations
// under the License.
-use async_trait::async_trait;
use http::StatusCode;
use super::backend::WebhdfsBackend;
diff --git a/core/src/services/yandex_disk/lister.rs b/core/src/services/yandex_disk/lister.rs
index 7cbcb4c012..7a1013309e 100644
--- a/core/src/services/yandex_disk/lister.rs
+++ b/core/src/services/yandex_disk/lister.rs
@@ -17,7 +17,7 @@
use std::sync::Arc;
-use async_trait::async_trait;
+
use super::core::parse_info;
use super::core::MetainformationResponse;