Fixing

MyJetTools · Jun 30, 2022 · b1fc3e8 · b1fc3e8
1 parent b21152c
commit b1fc3e8
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/background/metrics_updater.rs b/src/background/metrics_updater.rs
@@ -54,5 +54,12 @@ impl MyTimerTick for MetricsUpdater {
         self.app
             .metrics
             .update_fatal_errors_count(fatal_errors_count);
+
+        for reader in self.app.data_readers.get_all().await {
+            self.app
+                .metrics
+                .update_pending_to_sync(&reader.connection)
+                .await;
+        }
     }
 }
diff --git a/src/data_readers/data_reader.rs b/src/data_readers/data_reader.rs
@@ -113,7 +113,7 @@ impl DataReader {
         }
     }
 
-    fn get_pending_to_send(&self) -> usize {
+    pub fn get_pending_to_send(&self) -> usize {
         match &self.connection {
             DataReaderConnection::Tcp(connection) => connection.get_pending_to_send(),
             DataReaderConnection::Http(connection) => connection.get_pending_to_send(),