feat: add request handling metrics

common/Cargo.toml

@@ -44,6 +44,7 @@ autometrics = { version = "0.6.0", features = ["prometheus-exporter"] }
 tracing = "0.1.40"
 tower = "0.4.13"
 tower_governor = "0.1.0"
+prometheus = "0.13.3"
 
 [dev-dependencies]
 env_logger = "0.9.0"

common/src/indexer_service/http/indexer_service.rs

@@ -27,6 +27,7 @@ use tower_governor::{errors::display_error, governor::GovernorConfigBuilder, Gov
 use tracing::info;
 
 use crate::{
+    indexer_service::http::metrics::IndexerServiceMetrics,
     prelude::{
         attestation_signers, dispute_manager, escrow_accounts, indexer_allocations,
         AttestationSigner, DeploymentDetails, SubgraphClient,
@@ -152,6 +153,7 @@ where
     pub config: IndexerServiceConfig,
     pub release: IndexerServiceRelease,
     pub url_namespace: &'static str,
+    pub metrics_prefix: &'static str,
     pub extra_routes: Router<Arc<IndexerServiceState<I>>, Body>,
 }
 
@@ -163,6 +165,7 @@ where
     pub attestation_signers: Eventual<HashMap<Address, AttestationSigner>>,
     pub tap_manager: TapManager,
     pub service_impl: Arc<I>,
+    pub metrics: IndexerServiceMetrics,
 }
 
 pub struct IndexerService {}
@@ -172,6 +175,8 @@ impl IndexerService {
     where
         I: IndexerServiceImpl + Sync + Send + 'static,
     {
+        let metrics = IndexerServiceMetrics::new(options.metrics_prefix);
+
         let network_subgraph = Box::leak(Box::new(SubgraphClient::new(
             options
                 .config
@@ -258,6 +263,7 @@ impl IndexerService {
             attestation_signers,
             tap_manager,
             service_impl: Arc::new(options.service_impl),
+            metrics,
         });
 
         // Rate limits by allowing bursts of 10 requests and requiring 100ms of

common/src/indexer_service/http/metrics.rs

@@ -0,0 +1,34 @@
+use prometheus::{register_int_counter_vec, IntCounterVec};
+
+pub struct IndexerServiceMetrics {
+    pub requests: IntCounterVec,
+    pub successful_requests: IntCounterVec,
+    pub failed_requests: IntCounterVec,
+}
+
+impl IndexerServiceMetrics {
+    pub fn new(prefix: &str) -> Self {
+        IndexerServiceMetrics {
+            requests: register_int_counter_vec!(
+                format!("{prefix}_service_requests_total"),
+                "Incoming requests",
+                &["manifest"]
+            )
+            .unwrap(),
+
+            successful_requests: register_int_counter_vec!(
+                format!("{prefix}_service_requests_ok"),
+                "Successfully executed requests",
+                &["manifest"]
+            )
+            .unwrap(),
+
+            failed_requests: register_int_counter_vec!(
+                format!("{prefix}_service_requests_failed"),
+                "requests that failed to execute",
+                &["manifest"]
+            )
+            .unwrap(),
+        }
+    }
+}

common/src/indexer_service/http/mod.rs

@@ -1,5 +1,6 @@
 mod config;
 mod indexer_service;
+mod metrics;
 mod request_handler;
 mod scalar_receipt_header;
 

common/src/indexer_service/http/request_handler.rs

@@ -19,6 +19,7 @@ use super::{
     IndexerServiceImpl,
 };
 
+#[autometrics::autometrics]
 pub async fn request_handler<I>(
     Path(manifest_id): Path<DeploymentId>,
     TypedHeader(receipt): TypedHeader<ScalarReceipt>,
@@ -31,6 +32,12 @@ where
 {
     info!("Handling request for deployment `{manifest_id}`");
 
+    state
+        .metrics
+        .requests
+        .with_label_values(&[&manifest_id.to_string()])
+        .inc();
+
     let request =
         serde_json::from_slice(&body).map_err(|e| IndexerServiceError::InvalidRequest(e.into()))?;