From 5f1a1d4f357bb9c96fb57f882d90b6dbaa450e34 Mon Sep 17 00:00:00 2001 From: yifeizhuang Date: Mon, 25 Jul 2022 13:10:29 -0700 Subject: [PATCH] service: CalMetricRecorder.recordCallMetric is deprecated, use CalMetricRecorder.recordRequestCostMetric (#9410) --- .../testing/integration/TestServiceImpl.java | 2 +- .../io/grpc/services/CallMetricRecorder.java | 18 ++++++++++++++++++ .../grpc/services/CallMetricRecorderTest.java | 16 ++++++++-------- ...caMetricReportingServerInterceptorTest.java | 2 +- 4 files changed, 28 insertions(+), 10 deletions(-) diff --git a/interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java b/interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java index 0b18494fc0..a2c93d4ef8 100644 --- a/interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java +++ b/interop-testing/src/main/java/io/grpc/testing/integration/TestServiceImpl.java @@ -141,7 +141,7 @@ public class TestServiceImpl extends TestServiceGrpc.TestServiceImplBase { recorder.recordUtilizationMetric(entry.getKey(), entry.getValue()); } for (Map.Entry entry : report.getRequestCostMap().entrySet()) { - recorder.recordCallMetric(entry.getKey(), entry.getValue()); + recorder.recordRequestCostMetric(entry.getKey(), entry.getValue()); } } diff --git a/services/src/main/java/io/grpc/services/CallMetricRecorder.java b/services/src/main/java/io/grpc/services/CallMetricRecorder.java index 2feb5e28e6..d93f93606f 100644 --- a/services/src/main/java/io/grpc/services/CallMetricRecorder.java +++ b/services/src/main/java/io/grpc/services/CallMetricRecorder.java @@ -17,6 +17,7 @@ package io.grpc.services; import com.google.common.annotations.VisibleForTesting; +import com.google.errorprone.annotations.InlineMe; import io.grpc.Context; import io.grpc.ExperimentalApi; import java.util.Collections; @@ -92,8 +93,25 @@ public final class CallMetricRecorder { * * @return this recorder object * @since 1.47.0 + * @deprecated use {@link #recordRequestCostMetric} instead. + * This method will be removed in the future. */ + @Deprecated + @InlineMe(replacement = "this.recordRequestCostMetric(name, value)") public CallMetricRecorder recordCallMetric(String name, double value) { + return recordRequestCostMetric(name, value); + } + + /** + * Records a call metric measurement for request cost. + * If RPC has already finished, this method is no-op. + * + *

A latter record will overwrite its former name-sakes. + * + * @return this recorder object + * @since 1.48.1 + */ + public CallMetricRecorder recordRequestCostMetric(String name, double value) { if (disabled) { return this; } diff --git a/services/src/test/java/io/grpc/services/CallMetricRecorderTest.java b/services/src/test/java/io/grpc/services/CallMetricRecorderTest.java index 93745d53ed..9811d1da92 100644 --- a/services/src/test/java/io/grpc/services/CallMetricRecorderTest.java +++ b/services/src/test/java/io/grpc/services/CallMetricRecorderTest.java @@ -41,9 +41,9 @@ public class CallMetricRecorderTest { recorder.recordUtilizationMetric("util1", 154353.423); recorder.recordUtilizationMetric("util2", 0.1367); recorder.recordUtilizationMetric("util3", 1437.34); - recorder.recordCallMetric("cost1", 37465.12); - recorder.recordCallMetric("cost2", 10293.0); - recorder.recordCallMetric("cost3", 1.0); + recorder.recordRequestCostMetric("cost1", 37465.12); + recorder.recordRequestCostMetric("cost2", 10293.0); + recorder.recordRequestCostMetric("cost3", 1.0); recorder.recordCpuUtilizationMetric(0.1928); recorder.recordMemoryUtilizationMetric(47.4); @@ -65,11 +65,11 @@ public class CallMetricRecorderTest { @Test public void lastValueWinForMetricsWithSameName() { - recorder.recordCallMetric("cost1", 3412.5435); - recorder.recordCallMetric("cost2", 6441.341); - recorder.recordCallMetric("cost1", 6441.341); - recorder.recordCallMetric("cost1", 4654.67); - recorder.recordCallMetric("cost2", 75.83); + recorder.recordRequestCostMetric("cost1", 3412.5435); + recorder.recordRequestCostMetric("cost2", 6441.341); + recorder.recordRequestCostMetric("cost1", 6441.341); + recorder.recordRequestCostMetric("cost1", 4654.67); + recorder.recordRequestCostMetric("cost2", 75.83); recorder.recordMemoryUtilizationMetric(1.3); recorder.recordMemoryUtilizationMetric(3.1); recorder.recordUtilizationMetric("util1", 28374.21); diff --git a/xds/src/test/java/io/grpc/xds/orca/OrcaMetricReportingServerInterceptorTest.java b/xds/src/test/java/io/grpc/xds/orca/OrcaMetricReportingServerInterceptorTest.java index e0305b2e88..7ec7ef7b5e 100644 --- a/xds/src/test/java/io/grpc/xds/orca/OrcaMetricReportingServerInterceptorTest.java +++ b/xds/src/test/java/io/grpc/xds/orca/OrcaMetricReportingServerInterceptorTest.java @@ -90,7 +90,7 @@ public class OrcaMetricReportingServerInterceptorTest { entry.getValue()); } for (Map.Entry entry : applicationCostMetrics.entrySet()) { - CallMetricRecorder.getCurrent().recordCallMetric(entry.getKey(), + CallMetricRecorder.getCurrent().recordRequestCostMetric(entry.getKey(), entry.getValue()); } CallMetricRecorder.getCurrent().recordCpuUtilizationMetric(cpuUtilizationMetrics);