debug queue length

Author: JuArce

crates/batcher/src/lib.rs

@@ -1430,7 +1430,7 @@ impl Batcher {
 
         // Update metrics
         let queue_len = batch_state_lock.batch_queue.len();
-        let queue_size_bytes= 0;
+        let queue_size_bytes: i64= 100;
         // let queue_size_bytes = calculate_batch_size(&batch_state_lock.batch_queue)?;
         self.metrics
             .update_queue_metrics(queue_len as i64, queue_size_bytes as i64);

crates/batcher/src/metrics.rs

@@ -178,6 +178,7 @@ impl BatcherMetrics {
 
     pub fn update_queue_metrics(&self, queue_len: i64, queue_size: i64) {
         self.queue_len.set(queue_len);
+        println!("Queue length: {:?}", self.queue_len);
         self.queue_size_bytes.set(queue_size);
     }