added new metrics for graphs (#2029)

* added new metrics for graphs * added new required and roundtrip into metrics
kube-HPC · Nov 12, 2024 · 3f5f821 · 3f5f821
1 parent 4d6683c
commit 3f5f821
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 0 deletions.
diff --git a/core/pipeline-driver/lib/consts/metricsNames.js b/core/pipeline-driver/lib/consts/metricsNames.js
@@ -10,6 +10,8 @@ module.exports = {
         streaming_edge_processingTimeMs: 'pipeline_driver_streaming_edge_processing_time',
         streaming_edge_resRate: 'pipeline_driver_streaming_edge_res_rate',
         streaming_edge_reqRate: 'pipeline_driver_streaming_edge_req_rate',
+        streaming_edge_roundTripTimeMs: 'pipeline_driver_streaming_edge_round_trip',
+        streaming_edge_required: 'pipeline_driver_streaming_edge_required',
 
         streaming_pods_per_node: 'pipeline_driver_streaming_pods_per_node',
     },
@@ -38,6 +40,14 @@ module.exports = {
             propName: 'reqRate',
             registerZeroValue: true
         },
+        round_trip: {
+            propName: 'roundTripTimeMs',
+            registerZeroValue: false
+        },
+        required: {
+            propName: 'required',
+            registerZeroValue: true
+        }
     },
     streamingGeneralMetricToPropMap: {
         pods_per_node: {

diff --git a/core/pipeline-driver/lib/metrics/pipeline-metrics.js b/core/pipeline-driver/lib/metrics/pipeline-metrics.js
@@ -58,6 +58,16 @@ class PipelineMetrics {
             description: 'Pod count per node',
             labels: ['pipelineName', 'jobId', 'node'],
         });
+        metrics.addGaugeMeasure({
+            name: metricsNames.streaming_edge_roundTripTimeMs,
+            description: 'Round Trip in ms',
+            labels: ['pipelineName', 'jobId', 'source', 'target']
+        });
+        metrics.addGaugeMeasure({
+            name: metricsNames.streaming_edge_required,
+            description: 'Required Pods',
+            labels: ['pipelineName', 'jobId', 'source', 'target']
+        });
     }
 
     startMetrics(options) {