Skip to content

Commit 7117abe

Browse files
committed
Fixup 12645: Remove unsupported metrics and fix the name for mem_utilization
1 parent 63c5bf3 commit 7117abe

2 files changed

Lines changed: 4 additions & 45 deletions

File tree

xds/src/main/java/io/grpc/xds/internal/MetricReportUtils.java

Lines changed: 2 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -33,11 +33,8 @@ private MetricReportUtils() {}
3333
* <ul>
3434
* <li>"cpu_utilization" -> getCpuUtilization()</li>
3535
* <li>"application_utilization" -> getApplicationUtilization()</li>
36-
* <li>"memory_utilization" -> getMemoryUtilization()</li>
37-
* <li>"qps" -> getQps()</li>
38-
* <li>"eps" -> getEps()</li>
36+
* <li>"mem_utilization" -> getMemoryUtilization()</li>
3937
* <li>"utilization." -> lookup in utilizationMetrics</li>
40-
* <li>"request_cost." -> lookup in requestCostMetrics</li>
4138
* <li>"named_metrics." -> lookup in namedMetrics</li>
4239
* </ul>
4340
*
@@ -50,24 +47,14 @@ public static OptionalDouble getMetric(MetricReport report, String metricName) {
5047
return OptionalDouble.of(report.getCpuUtilization());
5148
} else if (metricName.equals("application_utilization")) {
5249
return OptionalDouble.of(report.getApplicationUtilization());
53-
} else if (metricName.equals("memory_utilization")) {
50+
} else if (metricName.equals("mem_utilization")) {
5451
return OptionalDouble.of(report.getMemoryUtilization());
55-
} else if (metricName.equals("qps")) {
56-
return OptionalDouble.of(report.getQps());
57-
} else if (metricName.equals("eps")) {
58-
return OptionalDouble.of(report.getEps());
5952
} else if (metricName.startsWith("utilization.")) {
6053
Map<String, Double> map = report.getUtilizationMetrics();
6154
Double val = map.get(metricName.substring("utilization.".length()));
6255
if (val != null) {
6356
return OptionalDouble.of(val);
6457
}
65-
} else if (metricName.startsWith("request_cost.")) {
66-
Map<String, Double> map = report.getRequestCostMetrics();
67-
Double val = map.get(metricName.substring("request_cost.".length()));
68-
if (val != null) {
69-
return OptionalDouble.of(val);
70-
}
7158
} else if (metricName.startsWith("named_metrics.")) {
7259
Map<String, Double> map = report.getNamedMetrics();
7360
Double val = map.get(metricName.substring("named_metrics.".length()));

xds/src/test/java/io/grpc/xds/internal/MetricReportUtilsTest.java

Lines changed: 2 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -51,28 +51,13 @@ public void getMetric_applicationUtilization() {
5151
}
5252

5353
@Test
54-
public void getMetric_memoryUtilization() {
54+
public void getMetric_memUtilization() {
5555
MetricReport report = createMetricReport(0.5, 0.1, 0.2, 10.0, 5.0, Collections.emptyMap());
56-
OptionalDouble result = MetricReportUtils.getMetric(report, "memory_utilization");
56+
OptionalDouble result = MetricReportUtils.getMetric(report, "mem_utilization");
5757
assertTrue(result.isPresent());
5858
assertEquals(0.2, result.getAsDouble(), 0.0001);
5959
}
6060

61-
@Test
62-
public void getMetric_qps() {
63-
MetricReport report = createMetricReport(0.5, 0.1, 0.2, 10.0, 5.0, Collections.emptyMap());
64-
OptionalDouble result = MetricReportUtils.getMetric(report, "qps");
65-
assertTrue(result.isPresent());
66-
assertEquals(10.0, result.getAsDouble(), 0.0001);
67-
}
68-
69-
@Test
70-
public void getMetric_eps() {
71-
MetricReport report = createMetricReport(0.5, 0.1, 0.2, 10.0, 5.0, Collections.emptyMap());
72-
OptionalDouble result = MetricReportUtils.getMetric(report, "eps");
73-
assertTrue(result.isPresent());
74-
assertEquals(5.0, result.getAsDouble(), 0.0001);
75-
}
7661

7762
@Test
7863
public void getMetric_utilizationMetric() {
@@ -88,19 +73,6 @@ public void getMetric_utilizationMetric() {
8873
assertFalse(MetricReportUtils.getMetric(report, "utilization.bar").isPresent());
8974
}
9075

91-
@Test
92-
public void getMetric_requestCostMetric() {
93-
Map<String, Double> requestCostMetrics = new HashMap<>();
94-
requestCostMetrics.put("foo", 4.56);
95-
MetricReport report = InternalCallMetricRecorder.createMetricReport(
96-
0, 0, 0, 0, 0, requestCostMetrics, Collections.emptyMap(), Collections.emptyMap());
97-
98-
OptionalDouble result = MetricReportUtils.getMetric(report, "request_cost.foo");
99-
assertTrue(result.isPresent());
100-
assertEquals(4.56, result.getAsDouble(), 0.0001);
101-
102-
assertFalse(MetricReportUtils.getMetric(report, "request_cost.bar").isPresent());
103-
}
10476

10577
@Test
10678
public void getMetric_namedMetric() {

0 commit comments

Comments
 (0)