[profiler] Display more balancer metrics

mihaibudiu · mihaibudiu · commit a6e92196a54a · 2026-05-12T07:44:53.000Z
Signed-off-by: Mihai Budiu &lt;mbudiu@feldera.com&gt;
diff --git a/js-packages/profiler-lib/src/profile.ts b/js-packages/profiler-lib/src/profile.ts
@@ -26,7 +26,7 @@ interface JsonMetricBase {
 interface MetricValue { };
 
 // Base types
-interface PersistentIdMetricValue extends MetricValue {
+interface StringMetricValue extends MetricValue {
     type: "string";
     value: string;
 }
@@ -54,6 +54,11 @@ interface BytesMetricValue {
     value: number;
 }
 
+interface BoolMetricValue {
+    type: "bool";
+    value: boolean;
+}
+
 interface PercentMetricValue {
     type: "percent";
     value: {
@@ -110,12 +115,13 @@ interface CacheStatsValue extends MetricValue {
 }
 
 type JsonMetricValue =
+    BoolMetricValue |
     CountMetricValue |
     BytesMetricValue |
     PercentMetricValue |
     DurationMetricValue |
     StatsMetricValue |
-    PersistentIdMetricValue |
+    StringMetricValue |
     DistributionValue |
     RetainmentValue |
     IntMetricValue |
@@ -375,6 +381,10 @@ class BooleanValue extends PropertyValue {
         this.value = id;
     }
 
+    static fromBoolMetric(value: BoolMetricValue): BooleanValue {
+        return new BooleanValue(value.value);
+    }
+
     getNumericValue(): Option<number> {
         return this.value ? Option.some(0) : Option.some(1);
     }
@@ -721,12 +731,17 @@ export class Measurement {
         let metric_id = metric.metric_id;
         let kind = metric_id.split("_").pop(); // count, bytes, etc
         if (metric.labels) {
-           let labels = metric.labels.map(e => e.join(":")).join(".");
-           if (metric.labels.length !== 0) {
-               metric_id = metric_id + "." + labels;
-           }
+            let labels = metric.labels.map(e => e.join(":")).join(".");
+            if (metric.labels.length !== 0) {
+                metric_id = metric_id + "." + labels;
+            }
         }
         switch (kind) {
+            case "bool": {
+                let m = metric.value as BoolMetricValue;
+                let value = BooleanValue.fromBoolMetric(m);
+                return [new Measurement(metric_id, Option.some(value))];
+            }
             case "bytes": {
                 let m = metric.value as BytesMetricValue;
                 let bytes = BytesValue.fromBytesMetric(m);
@@ -767,7 +782,7 @@ export class Measurement {
                 ];
             }
             case "id": { // persistent_id
-                let s = metric.value as PersistentIdMetricValue;
+                let s = metric.value as StringMetricValue;
                 let str = StringValue.fromString(s.value);
                 return [new Measurement(metric_id, Option.some(str))];
             }
@@ -845,6 +860,11 @@ export class Measurement {
                     new Measurement(metric_id + ".steps", Option.some(steps)),
                 ];
             }
+            case "policy": {
+                let s = metric.value as StringMetricValue;
+                let str = StringValue.fromString(s.value);
+                return [new Measurement(metric_id, Option.some(str))];
+            }
         }
         return [];
     }
