diff --git a/ecosystem/indexer-grpc/indexer-grpc-data-service/src/metrics.rs b/ecosystem/indexer-grpc/indexer-grpc-data-service/src/metrics.rs index 389d9e76e9a9b..777ffb5a616e0 100644 --- a/ecosystem/indexer-grpc/indexer-grpc-data-service/src/metrics.rs +++ b/ecosystem/indexer-grpc/indexer-grpc-data-service/src/metrics.rs @@ -79,9 +79,9 @@ pub static CONNECTION_COUNT: Lazy = Lazy::new(|| { /// Count of the short connections; i.e., < 10 seconds. pub static SHORT_CONNECTION_COUNT: Lazy = Lazy::new(|| { register_int_counter_vec!( - "indexer_grpc_data_service_short_connection_by_user_count", + "indexer_grpc_data_service_short_connection_by_user_processor_count", "Count of the short connections; i.e., < 10 seconds", - &["request_token", "email"], + &["request_token", "email", "processor"], ) .unwrap() }); diff --git a/ecosystem/indexer-grpc/indexer-grpc-data-service/src/service.rs b/ecosystem/indexer-grpc/indexer-grpc-data-service/src/service.rs index 2cebdc2393b21..1bc5b52325b49 100644 --- a/ecosystem/indexer-grpc/indexer-grpc-data-service/src/service.rs +++ b/ecosystem/indexer-grpc/indexer-grpc-data-service/src/service.rs @@ -174,6 +174,7 @@ impl RawData for RawDataServerWrapper { .with_label_values(&[ request_metadata.request_api_key_name.as_str(), request_metadata.request_email.as_str(), + request_metadata.processor_name.as_str(), ]) .inc(); // Connection will be dropped anyway, so we ignore the error here. @@ -205,6 +206,7 @@ impl RawData for RawDataServerWrapper { .with_label_values(&[ request_metadata.request_api_key_name.as_str(), request_metadata.request_email.as_str(), + request_metadata.processor_name.as_str(), ]) .inc(); // Connection will be dropped anyway, so we ignore the error here. @@ -374,6 +376,7 @@ impl RawData for RawDataServerWrapper { .with_label_values(&[ request_metadata.request_api_key_name.as_str(), request_metadata.request_email.as_str(), + request_metadata.processor_name.as_str(), ]) .inc(); }