diff --git a/instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_utilities.py b/instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_utilities.py index a57763558..8cf1f957c 100644 --- a/instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_utilities.py +++ b/instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/_utilities.py @@ -19,8 +19,6 @@ from time import time import grpc -from opentelemetry.sdk.metrics import Counter, ValueRecorder - class RpcInfo: def __init__( @@ -47,33 +45,29 @@ class TimedMetricRecorder: self._span_kind = span_kind if self._meter: - self._duration = self._meter.create_metric( + self._duration = self._meter.create_valuerecorder( name="{}/{}/duration".format(service_name, span_kind), description="Duration of grpc requests to the server", unit="ms", value_type=float, - metric_type=ValueRecorder, ) - self._error_count = self._meter.create_metric( + self._error_count = self._meter.create_counter( name="{}/{}/errors".format(service_name, span_kind), description="Number of errors that were returned from the server", unit="1", value_type=int, - metric_type=Counter, ) - self._bytes_in = self._meter.create_metric( + self._bytes_in = self._meter.create_counter( name="{}/{}/bytes_in".format(service_name, span_kind), description="Number of bytes received from the server", unit="by", value_type=int, - metric_type=Counter, ) - self._bytes_out = self._meter.create_metric( + self._bytes_out = self._meter.create_counter( name="{}/{}/bytes_out".format(service_name, span_kind), description="Number of bytes sent out through gRPC", unit="by", value_type=int, - metric_type=Counter, ) def record_bytes_in(self, bytes_in, method):