renaming meter to accumulator in metrics sdk context and fixing usages

in tests
open-telemetry · Nov 9, 2020 · baa6b10 · baa6b10
1 parent 2701445
commit baa6b10
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 11 deletions.
diff --git 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
@@ -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
@@ -26,18 +26,18 @@ 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.
     """
 
     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
@@ -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.
     """