add stopwatch (#3970)

core/src/subgraph/instance_manager.rs

@@ -285,6 +285,7 @@ impl<S: SubgraphStore> SubgraphInstanceManager<S> {
         let subgraph_metrics = Arc::new(SubgraphInstanceMetrics::new(
             registry.cheap_clone(),
             deployment.hash.as_str(),
+            stopwatch_metrics.clone(),
         ));
         let subgraph_metrics_unregister = subgraph_metrics.clone();
         let host_metrics = Arc::new(HostMetrics::new(

core/src/subgraph/trigger_processor.rs

@@ -35,16 +35,20 @@ where
 
         let mut host_mapping: Vec<(&T::Host, TriggerWithHandler<MappingTrigger<C>>)> = vec![];
 
-        for host in hosts {
-            let mapping_trigger = match host.match_and_decode(trigger, block, logger)? {
-                // Trigger matches and was decoded as a mapping trigger.
-                Some(mapping_trigger) => mapping_trigger,
+        {
+            let _section = subgraph_metrics.stopwatch.start_section("match_and_decode");
 
-                // Trigger does not match, do not process it.
-                None => continue,
-            };
+            for host in hosts {
+                let mapping_trigger = match host.match_and_decode(trigger, block, logger)? {
+                    // Trigger matches and was decoded as a mapping trigger.
+                    Some(mapping_trigger) => mapping_trigger,
 
-            host_mapping.push((&host, mapping_trigger));
+                    // Trigger does not match, do not process it.
+                    None => continue,
+                };
+
+                host_mapping.push((&host, mapping_trigger));
+            }
         }
 
         if host_mapping.is_empty() {

graph/src/components/metrics/subgraph.rs

@@ -3,16 +3,23 @@ use crate::prelude::{Gauge, Histogram, HostMetrics, MetricsRegistry};
 use std::collections::HashMap;
 use std::sync::Arc;
 
+use super::stopwatch::StopwatchMetrics;
+
 pub struct SubgraphInstanceMetrics {
     pub block_trigger_count: Box<Histogram>,
     pub block_processing_duration: Box<Histogram>,
     pub block_ops_transaction_duration: Box<Histogram>,
 
+    pub stopwatch: StopwatchMetrics,
     trigger_processing_duration: Box<Histogram>,
 }
 
 impl SubgraphInstanceMetrics {
-    pub fn new(registry: Arc<dyn MetricsRegistry>, subgraph_hash: &str) -> Self {
+    pub fn new(
+        registry: Arc<dyn MetricsRegistry>,
+        subgraph_hash: &str,
+        stopwatch: StopwatchMetrics,
+    ) -> Self {
         let block_trigger_count = registry
             .new_deployment_histogram(
                 "deployment_block_trigger_count",
@@ -51,6 +58,7 @@ impl SubgraphInstanceMetrics {
             block_processing_duration,
             trigger_processing_duration,
             block_ops_transaction_duration,
+            stopwatch,
         }
     }