chore: reset and update metrics

crates/topos-metrics/src/lib.rs

@@ -69,15 +69,19 @@ pub fn gather_metrics() -> String {
 }
 
 pub fn init_metrics() {
+    API_GRPC_CERTIFICATE_RECEIVED_TOTAL.reset();
     P2P_EVENT_STREAM_CAPACITY_TOTAL.reset();
     P2P_MESSAGE_RECEIVED_ON_GOSSIP_TOTAL.reset();
     P2P_MESSAGE_RECEIVED_ON_ECHO_TOTAL.reset();
     P2P_MESSAGE_RECEIVED_ON_READY_TOTAL.reset();
     P2P_MESSAGE_SENT_ON_GOSSIPSUB_TOTAL.reset();
+    DOUBLE_ECHO_ACTIVE_TASKS_COUNT.set(0);
     DOUBLE_ECHO_COMMAND_CHANNEL_CAPACITY_TOTAL.reset();
     DOUBLE_ECHO_BUFFER_CAPACITY_TOTAL.reset();
     DOUBLE_ECHO_CURRENT_BUFFER_SIZE.set(0);
     DOUBLE_ECHO_BUFFERED_MESSAGE_COUNT.set(0);
+    DOUBLE_ECHO_BROADCAST_CREATED_TOTAL.reset();
+    DOUBLE_ECHO_BROADCAST_FINISHED_TOTAL.reset();
     CERTIFICATE_RECEIVED_TOTAL.reset();
     CERTIFICATE_RECEIVED_FROM_GOSSIP_TOTAL.reset();
     CERTIFICATE_RECEIVED_FROM_API_TOTAL.reset();

crates/topos-tce-broadcast/src/double_echo/mod.rs

@@ -4,7 +4,6 @@ use std::collections::HashSet;
 use tce_transport::{ProtocolEvents, ReliableBroadcastParams};
 use tokio::sync::{mpsc, oneshot};
 use topos_core::uci::{Certificate, CertificateId};
-
 use topos_p2p::PeerId;
 use tracing::{error, info, warn};
 

crates/topos-tce-broadcast/src/lib.rs

@@ -43,9 +43,9 @@ use crate::sampler::SubscriptionsView;
 
 #[derive(Debug, PartialEq, Eq)]
 pub enum TaskStatus {
-    /// The task finished succesfully and broadcasted the certificate + received ready
+    /// The task finished successfully and broadcasted the certificate + received ready
     Success,
-    /// The task did not finish succesfully and stopped.
+    /// The task did not finish successfully and stopped.
     Failure,
 }
 

crates/topos-tce-broadcast/src/task_manager_channels/mod.rs

@@ -11,6 +11,10 @@ use crate::sampler::SubscriptionsView;
 use crate::TaskStatus;
 use crate::{constant, DoubleEchoCommand};
 use task::{Task, TaskContext};
+use topos_metrics::{
+    CERTIFICATE_RECEIVED_FROM_API_TOTAL, CERTIFICATE_RECEIVED_FROM_GOSSIP_TOTAL,
+    CERTIFICATE_RECEIVED_TOTAL,
+};
 
 /// The TaskManager is responsible for receiving messages from the network and distributing them
 /// among tasks. These tasks are either created if none for a certain CertificateID exists yet,
@@ -94,6 +98,13 @@ impl TaskManager {
 
                                     spawn(task.run());
 
+                                    CERTIFICATE_RECEIVED_TOTAL.inc();
+                                    if need_gossip {
+                                        CERTIFICATE_RECEIVED_FROM_API_TOTAL.inc();
+                                    } else {
+                                        CERTIFICATE_RECEIVED_FROM_GOSSIP_TOTAL.inc();
+                                    }
+
                                     if let Some(messages) = self.buffered_messages.remove(&cert.id) {
                                         let sink = task_context.sink.clone();
                                         spawn(async move {

crates/topos-tce-broadcast/src/task_manager_futures/mod.rs

@@ -7,6 +7,9 @@ use std::pin::Pin;
 use tce_transport::{ProtocolEvents, ReliableBroadcastParams};
 use tokio::{spawn, sync::mpsc};
 use topos_core::uci::CertificateId;
+use topos_metrics::CERTIFICATE_RECEIVED_FROM_API_TOTAL;
+use topos_metrics::CERTIFICATE_RECEIVED_FROM_GOSSIP_TOTAL;
+use topos_metrics::CERTIFICATE_RECEIVED_TOTAL;
 use topos_metrics::DOUBLE_ECHO_ACTIVE_TASKS_COUNT;
 use tracing::warn;
 
@@ -113,6 +116,13 @@ impl TaskManager {
 
                                     DOUBLE_ECHO_ACTIVE_TASKS_COUNT.inc();
 
+                                    CERTIFICATE_RECEIVED_TOTAL.inc();
+                                    if need_gossip {
+                                        CERTIFICATE_RECEIVED_FROM_API_TOTAL.inc();
+                                    } else {
+                                        CERTIFICATE_RECEIVED_FROM_GOSSIP_TOTAL.inc();
+                                    }
+
                                     entry.insert(task_context);
                                 }
                                 std::collections::hash_map::Entry::Occupied(_) => {},