bug fix

1. saving meta json file
2. change statistics format

Cargo.toml

@@ -19,4 +19,5 @@ dirs = "3.0.2"
 rdkafka = { version = "0.33.2", default-features = false, features = ["cmake-build"] }
 redis = { version = "0.23", features = ["tokio-comp"] }
 hex = "0.4"
-byteorder = "1.4.3"
+byteorder = "1.4.3"
+chrono = "0.4"

src/main.rs

@@ -76,6 +76,7 @@ fn serve(cfg_path: &String) {
     //println!("text result is :{:?}", text_resp);
     let (file, pos) = check_valid_pos(posMng.clone(), text_resp, config.from_start.is_some_and(|b|b));
     println!("{file} {pos}");
+    update_name_pos(posMng.clone(), &file, pos);
 
     let dump = ComBinLogDump {
         pos,
@@ -92,7 +93,7 @@ fn serve(cfg_path: &String) {
     let mut statistics= Statistics::new();
     loop {
         let (_, buf) = conn.read_package::<Vec<u8>>().unwrap();
-        statistics.feed_bytes(buf.payload.len());
+        statistics.feed_bytes(seq_idx, buf.payload.len());
         let event_result = EventRaw::decode(buf.payload.as_bytes());
         if let Ok((_, ev)) = event_result {
             if ev.header.event_type == 19 {

src/message_queue.rs

@@ -76,6 +76,7 @@ fn outgiving_body(rx: Receiver<QueueMessage>, mq_ins: &mut dyn QueueClient, posM
         if let Ok(msg) = rx.recv() {
             mq_ins.queue_message(&msg);
             update_pos(posMng.clone(), msg.pos);
+            //println!("msg sent!");
         }
     }
 }