chore: change log subscriber from env_logger to tracing-subscriber

core/Cargo.toml

@@ -217,7 +217,6 @@ uuid = { version = "1", features = ["serde", "v4"] }
 [dev-dependencies]
 criterion = { version = "0.4", features = ["async", "async_tokio"] }
 dotenvy = "0.15"
-env_logger = "0.10"
 opentelemetry = { version = "0.19", default-features = false, features = [
   "trace",
 ] }

core/examples/object.rs

@@ -26,8 +26,8 @@ use opendal::Result;
 /// Visit [`opendal::Object`] for more object level APIs.
 #[tokio::main]
 async fn main() -> Result<()> {
-    let _ = env_logger::builder()
-        .filter_level(log::LevelFilter::Debug)
+    let _ = tracing_subscriber::fmt()
+        .with_env_filter("debug")
         .try_init();
 
     // Pick a builder and configure it.

core/src/layers/immutable_index.rs

@@ -284,7 +284,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_list() -> Result<()> {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let mut iil = ImmutableIndexLayer::default();
         for i in ["file", "dir/", "dir/file", "dir_without_prefix/file"] {
@@ -322,7 +322,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_scan() -> Result<()> {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let mut iil = ImmutableIndexLayer::default();
         for i in ["file", "dir/", "dir/file", "dir_without_prefix/file"] {
@@ -362,7 +362,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_list_dir() -> Result<()> {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let mut iil = ImmutableIndexLayer::default();
         for i in [
@@ -423,7 +423,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_walk_top_down_dir() -> Result<()> {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let mut iil = ImmutableIndexLayer::default();
         for i in [

core/src/layers/retry.rs

@@ -1012,7 +1012,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_retry_read() {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let builder = MockBuilder::default();
         let op = Operator::new(builder.clone())
@@ -1034,7 +1034,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_retry_list() {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let builder = MockBuilder::default();
         let op = Operator::new(builder.clone())
@@ -1058,7 +1058,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_retry_batch() {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let builder = MockBuilder::default();
         // set to a lower delay to make it run faster

core/src/raw/oio/to_flat_pager.rs

@@ -299,7 +299,7 @@ mod tests {
 
     #[test]
     fn test_blocking_list() -> Result<()> {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let acc = MockService::new();
         let mut pager = to_flat_pager(acc, "x/", 10);

core/src/raw/oio/to_hierarchy_pager.rs

@@ -198,7 +198,7 @@ mod tests {
 
     #[test]
     fn test_blocking_list() -> Result<()> {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let pager = MockPager::new(&["x/x/", "x/y/", "y/", "x/x/x", "y/y", "xy/", "z", "y/a"]);
         let mut pager = to_hierarchy_pager(pager, "");

core/src/services/http/backend.rs

@@ -406,7 +406,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_read() -> Result<()> {
-        let _ = env_logger::builder().is_test(true).try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let mock_server = MockServer::start().await;
         Mock::given(method("GET"))
@@ -432,7 +432,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_read_via_basic_auth() -> Result<()> {
-        let _ = env_logger::builder().is_test(true).try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let (username, password) = ("your_username", "your_password");
 
@@ -462,7 +462,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_read_via_bearer_auth() -> Result<()> {
-        let _ = env_logger::builder().is_test(true).try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let token = "your_token";
 
@@ -492,7 +492,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_stat() -> Result<()> {
-        let _ = env_logger::builder().is_test(true).try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let mock_server = MockServer::start().await;
         Mock::given(method("HEAD"))
@@ -514,7 +514,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_read_with() -> Result<()> {
-        let _ = env_logger::builder().is_test(true).try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let mock_server = MockServer::start().await;
         Mock::given(method("GET"))
@@ -543,7 +543,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_stat_with() -> Result<()> {
-        let _ = env_logger::builder().is_test(true).try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let mock_server = MockServer::start().await;
         Mock::given(method("HEAD"))

core/src/services/s3/backend.rs

@@ -1223,7 +1223,7 @@ mod tests {
 
     #[test]
     fn test_build_endpoint() {
-        let _ = env_logger::try_init();
+        let _ = tracing_subscriber::fmt().with_test_writer().try_init();
 
         let endpoint_cases = vec![
             Some("s3.amazonaws.com"),

core/tests/behavior/utils.rs

@@ -39,7 +39,7 @@ use sha2::Sha256;
 /// - If `opendal_{schema}_test` is on, construct a new Operator with given root.
 /// - Else, returns a `None` to represent no valid config for operator.
 pub fn init_service<B: Builder>() -> Option<Operator> {
-    let _ = env_logger::builder().is_test(true).try_init();
+    let _ = tracing_subscriber::fmt().with_test_writer().try_init();
     let _ = dotenvy::dotenv();
 
     let prefix = format!("opendal_{}_", B::SCHEME);