Merge pull request #793 from Migorithm/feat/tracing-appender

feat: shared logging

Author: Migorithm

Cargo.lock

@@ -30,4 +30,8 @@ cli:
 
 cli-cluster:
 	@echo '🚀 Starting client in local_test/cli...'
-	cargo run -p duva-client -- --port $(p) --cluster-mode
+	cargo run -p duva-client -- --port $(p) --cluster-mode
+
+
+sort_log:
+	jq -c '.' duva/shared.log | sort -t'"' -k4,4 duva/shared.log > shared_log_sorted.json

Makefile

@@ -1,7 +1,6 @@
 mod node_connections;
 mod read_stream;
 mod write_stream;
-use std::collections::HashMap;
 
 use crate::broker::node_connections::NodeConnections;
 use crate::command::{CommandQueue, CommandToServer, InputContext, RoutingRule};

duva-client/src/broker/mod.rs

@@ -8,26 +8,31 @@ edition = "2024"
 
 # DON'T EDIT THIS!
 [dependencies]
-anyhow = "1.0.97"                                   # error handling
-bytes = "1.10.1"                                    # helps manage buffers
-thiserror = "2.0.12"                                # error handling
+anyhow = "1.0.97" # error handling
+bytes = "1.10.1" # helps manage buffers
+thiserror = "2.0.12" # error handling
 tokio = { version = "1.44.2", features = ["full"] }
-rand = { version = "0.9.0", features = ["std"] }    # async networking
-futures = "0.3.31"                                  # async networking
-memmap2 = "0.9.5"                                   # memory mapping
+rand = { version = "0.9.0", features = ["std"] } # async networking
+futures = "0.3.31" # async networking
+memmap2 = "0.9.5" # memory mapping
 chrono = "0.4.40"
-bincode = { version = "2.0.1" }                     # serialization
-uuid = { version = "1.16.0", features = ["v7"] }    # unique id generation
+bincode = { version = "2.0.1" } # serialization
+uuid = { version = "1.16.0", features = ["v7"] } # unique id generation
 memchr = "2.7.4"
 regex = "1.11.1"
 tracing = "0.1.41"
-tracing-subscriber = "0.3.19"
-async-trait = "0.1.88"                              # async trait support
+tracing-subscriber = { version = "0.3", features = [
+    "env-filter",
+    "json",
+    "time",
+] }
+tracing-appender = "0.2.3"
+async-trait = "0.1.88" # async trait support
 lzf = { version = "1.0.0" }
 
 [dev-dependencies]
 tempfile = "3.19.1"
-criterion = "0.6.0"
+criterion = "0.7.0"
 
 [[bench]]
 name = "benchmark"

duva/Cargo.toml

@@ -22,7 +22,7 @@ pub struct Environment {
     pub ttl_mills: u128,
     pub append_only: bool,
     pub tpp: String,
-    pub log_level: tracing::Level,
+    pub log_level: tracing::level_filters::LevelFilter,
 }
 
 impl Environment {
@@ -37,7 +37,7 @@ impl Environment {
                 ttl: u128 = 60000,
                 append_only: bool = false,
                 tpp: String = "duva.tp".to_string(),
-                log_level : tracing::Level = tracing::Level::INFO,
+                log_level : tracing::level_filters::LevelFilter = tracing::level_filters::LevelFilter::INFO,
             },
             optional: {
                 replicaof

duva/src/config.rs

@@ -981,7 +981,6 @@ impl<T: TWriteAheadLog> ClusterActor<T> {
         // * Raft followers should truncate their log starting at prev_log_index + 1 and then append the new entries
         // * Just returning an error is breaking consistency
         if let Some(prev_entry) = self.logger.read_at(prev_log_index) {
-            debug!("Previous log entry: {:?}", prev_entry);
             if prev_entry.term != prev_log_term {
                 // ! Term mismatch -> triggers log truncation
                 err!("Term mismatch: {} != {}", prev_entry.term, prev_log_term);