Skip to content

Commit c7f0965

Browse files
committed
service: CalMetricRecorder.recordCallMetric is deprecated, use CalMetricRecorder.recordRequestCostMetric (#9410)
1 parent 0c287af commit c7f0965

File tree

4 files changed

+28
-10
lines changed

4 files changed

+28
-10
lines changed

interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ private static void echoCallMetricsFromPayload(TestOrcaReport report) {
141141
recorder.recordUtilizationMetric(entry.getKey(), entry.getValue());
142142
}
143143
for (Map.Entry<String, Double> entry : report.getRequestCostMap().entrySet()) {
144-
recorder.recordCallMetric(entry.getKey(), entry.getValue());
144+
recorder.recordRequestCostMetric(entry.getKey(), entry.getValue());
145145
}
146146
}
147147

services/src/main/java/io/grpc/services/CallMetricRecorder.java

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
package io.grpc.services;
1818

1919
import com.google.common.annotations.VisibleForTesting;
20+
import com.google.errorprone.annotations.InlineMe;
2021
import io.grpc.Context;
2122
import io.grpc.ExperimentalApi;
2223
import java.util.Collections;
@@ -92,8 +93,25 @@ public CallMetricRecorder recordUtilizationMetric(String name, double value) {
9293
*
9394
* @return this recorder object
9495
* @since 1.47.0
96+
* @deprecated use {@link #recordRequestCostMetric} instead.
97+
* This method will be removed in the future.
9598
*/
99+
@Deprecated
100+
@InlineMe(replacement = "this.recordRequestCostMetric(name, value)")
96101
public CallMetricRecorder recordCallMetric(String name, double value) {
102+
return recordRequestCostMetric(name, value);
103+
}
104+
105+
/**
106+
* Records a call metric measurement for request cost.
107+
* If RPC has already finished, this method is no-op.
108+
*
109+
* <p>A latter record will overwrite its former name-sakes.
110+
*
111+
* @return this recorder object
112+
* @since 1.48.1
113+
*/
114+
public CallMetricRecorder recordRequestCostMetric(String name, double value) {
97115
if (disabled) {
98116
return this;
99117
}

services/src/test/java/io/grpc/services/CallMetricRecorderTest.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -41,9 +41,9 @@ public void dumpDumpsAllSavedMetricValues() {
4141
recorder.recordUtilizationMetric("util1", 154353.423);
4242
recorder.recordUtilizationMetric("util2", 0.1367);
4343
recorder.recordUtilizationMetric("util3", 1437.34);
44-
recorder.recordCallMetric("cost1", 37465.12);
45-
recorder.recordCallMetric("cost2", 10293.0);
46-
recorder.recordCallMetric("cost3", 1.0);
44+
recorder.recordRequestCostMetric("cost1", 37465.12);
45+
recorder.recordRequestCostMetric("cost2", 10293.0);
46+
recorder.recordRequestCostMetric("cost3", 1.0);
4747
recorder.recordCpuUtilizationMetric(0.1928);
4848
recorder.recordMemoryUtilizationMetric(47.4);
4949

@@ -65,11 +65,11 @@ public void noMetricsRecordedAfterSnapshot() {
6565

6666
@Test
6767
public void lastValueWinForMetricsWithSameName() {
68-
recorder.recordCallMetric("cost1", 3412.5435);
69-
recorder.recordCallMetric("cost2", 6441.341);
70-
recorder.recordCallMetric("cost1", 6441.341);
71-
recorder.recordCallMetric("cost1", 4654.67);
72-
recorder.recordCallMetric("cost2", 75.83);
68+
recorder.recordRequestCostMetric("cost1", 3412.5435);
69+
recorder.recordRequestCostMetric("cost2", 6441.341);
70+
recorder.recordRequestCostMetric("cost1", 6441.341);
71+
recorder.recordRequestCostMetric("cost1", 4654.67);
72+
recorder.recordRequestCostMetric("cost2", 75.83);
7373
recorder.recordMemoryUtilizationMetric(1.3);
7474
recorder.recordMemoryUtilizationMetric(3.1);
7575
recorder.recordUtilizationMetric("util1", 28374.21);

xds/src/test/java/io/grpc/xds/orca/OrcaMetricReportingServerInterceptorTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public void unaryRpc(
9090
entry.getValue());
9191
}
9292
for (Map.Entry<String, Double> entry : applicationCostMetrics.entrySet()) {
93-
CallMetricRecorder.getCurrent().recordCallMetric(entry.getKey(),
93+
CallMetricRecorder.getCurrent().recordRequestCostMetric(entry.getKey(),
9494
entry.getValue());
9595
}
9696
CallMetricRecorder.getCurrent().recordCpuUtilizationMetric(cpuUtilizationMetrics);

0 commit comments

Comments
 (0)