Set up configurable FFI/Rust driver logging

c/BUILD

@@ -45,8 +45,8 @@ rust_static_library(
 
         "@crates//:chrono",
         "@crates//:itertools",
-        "@crates//:env_logger",
         "@crates//:tracing",
+        "@crates//:tracing-subscriber",
     ],
     tags = ["crate-name=typedb_driver_clib"],
 )
@@ -71,9 +71,8 @@ rust_shared_library(
 
         "@crates//:chrono",
         "@crates//:itertools",
-        "@crates//:env_logger",
-        "@crates//:log",
         "@crates//:tracing",
+        "@crates//:tracing-subscriber",
     ],
     tags = ["crate-name=typedb_driver_clib"],
 )

c/Cargo.toml

@@ -14,19 +14,14 @@ features = {}
 
 [dependencies]
 
-	[dependencies.env_logger]
-		features = ["auto-color", "color", "default", "humantime", "regex"]
-		version = "0.10.2"
-		default-features = false
-
 	[dependencies.tracing]
 		features = ["attributes", "default", "log", "std", "tracing-attributes"]
 		version = "0.1.41"
 		default-features = false
 
-	[dependencies.log]
-		features = ["kv", "kv_unstable", "std", "value-bag"]
-		version = "0.4.27"
+	[dependencies.tracing-subscriber]
+		features = ["alloc", "ansi", "default", "env-filter", "fmt", "matchers", "nu-ansi-term", "once_cell", "regex", "registry", "sharded-slab", "smallvec", "std", "thread_local", "tracing", "tracing-log"]
+		version = "0.3.19"
 		default-features = false
 
 	[dependencies.typedb-driver]

c/src/concept/mod.rs

@@ -19,7 +19,6 @@
 
 use std::ptr::addr_of_mut;
 
-use itertools::Itertools;
 use typedb_driver::{answer::ConceptRow, concept::Concept, BoxPromise, Promise, Result};
 
 use super::{iterator::iterator_try_next, memory::free};

c/src/error.rs

@@ -24,8 +24,8 @@ use std::{
     sync::Arc,
 };
 
-use env_logger::Env;
 use tracing::{debug, warn};
+use tracing_subscriber::{fmt as tracing_fmt, layer::SubscriberExt, util::SubscriberInitExt, EnvFilter};
 use typedb_driver::{Error, Result};
 
 use super::memory::{free, release_arc, release_optional, release_string};
@@ -35,12 +35,41 @@ thread_local! {
 }
 
 /// Enables logging in the TypeDB driver.
+///
+///  This function sets up tracing with the following priority:
+///  1. TYPEDB_DRIVER_LOG environment variable (if set). Use TYPEDB_DRIVER_CLIB_LOG to see memory exchanges
+///  2. RUST_LOG environment variable (if set)
+///  3. Default level (INFO)
+///
+///  The logging is initialized only once using a static flag to prevent
+///  multiple initializations in applications that create multiple drivers.
 #[no_mangle]
 pub extern "C" fn init_logging() {
-    const ENV_VAR: &str = "TYPEDB_DRIVER_LOG_LEVEL";
-    if let Err(err) = env_logger::try_init_from_env(Env::new().filter(ENV_VAR)) {
-        warn!("{err}");
-    }
+    use std::sync::Once;
+    static INIT: Once = Once::new();
+    INIT.call_once(|| {
+        let clib_level = if let Ok(typedb_driver_clib_log) = std::env::var("TYPEDB_DRIVER_CLIB_LOG") {
+            typedb_driver_clib_log
+        } else {
+            "info".to_owned()
+        };
+        // Try to get log level from TYPEDB_DRIVER_LOG first
+        let env_filter = if let Ok(typedb_log_level) = std::env::var("TYPEDB_DRIVER_LOG") {
+            EnvFilter::new(&format!("typedb_driver={},typedb_driver_clib={}", typedb_log_level, clib_level))
+        } else if let Ok(rust_log) = std::env::var("RUST_LOG") {
+            // If RUST_LOG is set, use it but scope it to typedb_driver only
+            EnvFilter::new(&format!("typedb_driver={},typedb_driver_clib={}", rust_log, clib_level))
+        } else {
+            EnvFilter::new(&format!("typedb_driver=info,typedb_driver_clib={}", clib_level))
+        };
+
+        // Initialize the tracing subscriber
+        if let Err(e) =
+            tracing_subscriber::registry().with(env_filter).with(tracing_fmt::layer().with_target(false)).try_init()
+        {
+            eprintln!("Failed to initialize logging: {}", e);
+        }
+    });
 }
 
 fn ok_record<T>(result: Result<T>) -> Option<T> {

docs/modules/ROOT/partials/rust/connection/TypeDBDriver.adoc

@@ -32,27 +32,6 @@ Result
 driver.force_close()
 ----
 
-[#_struct_TypeDBDriver_init_logging_]
-==== init_logging
-
-[source,rust]
-----
-pub fn init_logging()
-----
-
-Initialize logging configuration for the TypeDB driver.
-
-This function sets up tracing with the following priority:
-
-The logging is initialized only once using a static flag to prevent multiple initializations in applications that create multiple drivers.
-
-[caption=""]
-.Returns
-[source,rust]
-----
-null
-----
-
 [#_struct_TypeDBDriver_is_open_]
 ==== is_open
 

rust/BUILD

@@ -35,7 +35,6 @@ typedb_driver_deps = [
     "@crates//:futures",
     "@crates//:http",
     "@crates//:itertools",
-    "@crates//:log",
     "@crates//:prost",
     "@crates//:serde",
     "@crates//:tokio",

rust/src/driver.rs

@@ -54,45 +54,6 @@ impl TypeDBDriver {
 
     pub const DEFAULT_ADDRESS: &'static str = "localhost:1729";
 
-    /// Initialize logging configuration for the TypeDB driver.
-    ///
-    /// This function sets up tracing with the following priority:
-    /// 1. TYPEDB_DRIVER_LOG environment variable (if set). Use TYPEDB_DRIVER_CLIB_LOG to see memory exchanges
-    /// 1.  environment variable (if set)
-    /// 2. RUST_LOG environment variable (if set)
-    /// 3. Default level (INFO)
-    ///
-    /// The logging is initialized only once using a static flag to prevent
-    /// multiple initializations in applications that create multiple drivers.
-    pub fn init_logging() {
-        use std::sync::Once;
-        static INIT: Once = Once::new();
-
-        INIT.call_once(|| {
-            let clib_level = if let Ok(typedb_driver_clib_log) = std::env::var("TYPEDB_DRIVER_CLIB_LOG") {
-                typedb_driver_clib_log
-            } else {
-                "info".to_owned()
-            };
-            // Try to get log level from TYPEDB_DRIVER_LOG first
-            let env_filter = if let Ok(typedb_log_level) = std::env::var("TYPEDB_DRIVER_LOG") {
-                EnvFilter::new(&format!("typedb_driver={},typedb_driver_clib={}", typedb_log_level, clib_level))
-            } else if let Ok(rust_log) = std::env::var("RUST_LOG") {
-                // If RUST_LOG is set, use it but scope it to typedb_driver only
-                EnvFilter::new(&format!("typedb_driver={},typedb_driver_clib={}", rust_log, clib_level))
-            } else {
-                EnvFilter::new(&format!("typedb_driver=info,typedb_driver_clib={}", clib_level))
-            };
-
-            // Initialize the tracing subscriber
-            if let Err(e) =
-                tracing_subscriber::registry().with(env_filter).with(tracing_fmt::layer().with_target(false)).try_init()
-            {
-                eprintln!("Failed to initialize logging: {}", e);
-            }
-        });
-    }
-
     /// Creates a new TypeDB Server connection.
     ///
     /// # Arguments
@@ -153,8 +114,6 @@ impl TypeDBDriver {
         driver_options: DriverOptions,
         driver_lang: impl AsRef<str>,
     ) -> Result<Self> {
-        Self::init_logging();
-
         debug!("Initializing TypeDB driver with description: {}", driver_lang.as_ref());
         let id = address.as_ref().to_string();
         let address: Address = id.parse()?;