Merge pull request #146 from wepay/client-id-metric-typo

smithakoduri · web-flow · commit e3217661a2c4 · 2021-08-31T10:07:59.000-07:00
Fix WaltzClient metric typo
diff --git a/waltz-client/src/main/java/com/wepay/waltz/client/WaltzClient.java b/waltz-client/src/main/java/com/wepay/waltz/client/WaltzClient.java
@@ -267,7 +267,7 @@ private static WaltzClientDriver getWaltzClientDriver(WaltzClientCallbacks callb
 
     private void registerMetrics() {
         REGISTRY.gauge(metricsGroup, "cluster-name", (Gauge<String>) () -> clusterName());
-        REGISTRY.gauge(metricsGroup, "cluster-id", (Gauge<Integer>) () -> clientId());
+        REGISTRY.gauge(metricsGroup, "client-id", (Gauge<Integer>) () -> clientId());
         REGISTRY.gauge(metricsGroup, "num-active-partitions", (Gauge<Integer>) () -> getPartitions().size());
         REGISTRY.gauge(metricsGroup, "active-partition-ids", (Gauge<Set<Integer>>) () -> getPartitions());
     }

Original file line number	Diff line number	Diff line change
`@@ -267,7 +267,7 @@ private static WaltzClientDriver getWaltzClientDriver(WaltzClientCallbacks callb`
`267`	`267`
`268`	`268`	`private void registerMetrics() {`
`269`	`269`	`REGISTRY.gauge(metricsGroup, "cluster-name", (Gauge<String>) () -> clusterName());`
`270`		`- REGISTRY.gauge(metricsGroup, "cluster-id", (Gauge<Integer>) () -> clientId());`
	`270`	`+ REGISTRY.gauge(metricsGroup, "client-id", (Gauge<Integer>) () -> clientId());`
`271`	`271`	`REGISTRY.gauge(metricsGroup, "num-active-partitions", (Gauge<Integer>) () -> getPartitions().size());`
`272`	`272`	`REGISTRY.gauge(metricsGroup, "active-partition-ids", (Gauge<Set<Integer>>) () -> getPartitions());`
`273`	`273`	`}`