diff --git a/opentelemetry-instrumentation/tests/test_metric.py b/opentelemetry-instrumentation/tests/test_metric.py index 14c39d85e09..8e676c737e2 100644 --- a/opentelemetry-instrumentation/tests/test_metric.py +++ b/opentelemetry-instrumentation/tests/test_metric.py @@ -41,7 +41,7 @@ def test_init(self): mixin = MetricMixin() mixin.init_metrics("test", 1.0) meter = mixin.meter - self.assertTrue(isinstance(meter, metrics.Meter)) + self.assertTrue(isinstance(meter, metrics.Accumulator)) self.assertEqual(meter.instrumentation_info.name, "test") self.assertEqual(meter.instrumentation_info.version, 1.0) diff --git a/opentelemetry-sdk/src/opentelemetry/sdk/metrics/__init__.py b/opentelemetry-sdk/src/opentelemetry/sdk/metrics/__init__.py index 8207aa57553..9b471159571 100644 --- a/opentelemetry-sdk/src/opentelemetry/sdk/metrics/__init__.py +++ b/opentelemetry-sdk/src/opentelemetry/sdk/metrics/__init__.py @@ -145,7 +145,7 @@ def __init__( description: str, unit: str, value_type: Type[metrics_api.ValueT], - meter: "Meter", + meter: "Accumulator", enabled: bool = True, ): self.name = name @@ -339,7 +339,7 @@ def __init__( self.aggregator = aggregator -class Meter(metrics_api.Meter): +class Accumulator(metrics_api.Meter): """See `opentelemetry.metrics.Meter`. Args: @@ -561,7 +561,7 @@ def get_meter( if not instrumenting_module_name: # Reject empty strings too. instrumenting_module_name = "ERROR:MISSING MODULE NAME" logger.error("get_meter called with missing module name.") - return Meter( + return Accumulator( self, InstrumentationInfo( instrumenting_module_name, instrumenting_library_version diff --git a/opentelemetry-sdk/src/opentelemetry/sdk/metrics/export/controller.py b/opentelemetry-sdk/src/opentelemetry/sdk/metrics/export/controller.py index e095ebbb72c..7c69468e617 100644 --- a/opentelemetry-sdk/src/opentelemetry/sdk/metrics/export/controller.py +++ b/opentelemetry-sdk/src/opentelemetry/sdk/metrics/export/controller.py @@ -26,7 +26,7 @@ class PushController(threading.Thread): exports them and performs some post-processing. Args: - meter: The meter used to collect metrics. + accumulator: The meter used to collect metrics. exporter: The exporter used to export metrics. interval: The collect/export interval in seconds. """ @@ -34,10 +34,10 @@ class PushController(threading.Thread): daemon = True def __init__( - self, meter: Meter, exporter: MetricsExporter, interval: float + self, accumulator: Meter, exporter: MetricsExporter, interval: float ): super().__init__() - self.meter = meter + self.accumulator = accumulator self.exporter = exporter self.interval = interval self.finished = threading.Event() @@ -54,10 +54,10 @@ def shutdown(self): def tick(self): # Collect all of the meter's metrics to be exported - self.meter.collect() + self.accumulator.collect() # Export the collected metrics token = attach(set_value("suppress_instrumentation", True)) - self.exporter.export(self.meter.processor.checkpoint_set()) + self.exporter.export(self.accumulator.processor.checkpoint_set()) detach(token) # Perform post-exporting logic - self.meter.processor.finished_collection() + self.accumulator.processor.finished_collection() diff --git a/opentelemetry-sdk/src/opentelemetry/sdk/metrics/export/processor.py b/opentelemetry-sdk/src/opentelemetry/sdk/metrics/export/processor.py index fa16f5f4ea7..7262d15a861 100644 --- a/opentelemetry-sdk/src/opentelemetry/sdk/metrics/export/processor.py +++ b/opentelemetry-sdk/src/opentelemetry/sdk/metrics/export/processor.py @@ -23,7 +23,7 @@ class Processor: """Base class for all processor types. The processor is responsible for storing the aggregators and aggregated - values received from updates from metrics in the meter. The stored values + values received from updates from metrics in the accumulator. The stored values will be sent to an exporter for exporting. """