rename Record class in metrics sdk to Accumulation

open-telemetry · Nov 17, 2020 · 0c8a269 · 0c8a269
1 parent c4950a3
commit 0c8a269
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 11 deletions.
diff --git a/opentelemetry-sdk/src/opentelemetry/sdk/metrics/__init__.py b/opentelemetry-sdk/src/opentelemetry/sdk/metrics/__init__.py
@@ -325,7 +325,7 @@ class ValueObserver(Observer, metrics_api.ValueObserver):
     """See `opentelemetry.metrics.ValueObserver`."""
 
 
-class Record:
+class Accumulation:
     """Container class used for processing in the `Processor`"""
 
     def __init__(
@@ -382,10 +382,10 @@ def _collect_metrics(self) -> None:
                     bound_instrument,
                 ) in metric.bound_instruments.items():
                     for view_data in bound_instrument.view_datas:
-                        record = Record(
+                        accumulation = Accumulation(
                             metric, view_data.labels, view_data.aggregator
                         )
-                        self.processor.process(record)
+                        self.processor.process(accumulation)
 
                     if bound_instrument.ref_count() == 0:
                         to_remove.append(labels)
@@ -404,8 +404,8 @@ def _collect_observers(self) -> None:
                     continue
 
                 for labels, aggregator in observer.aggregators.items():
-                    record = Record(observer, labels, aggregator)
-                    self.processor.process(record)
+                    accumulation = Accumulation(observer, labels, aggregator)
+                    self.processor.process(accumulation)
 
     def record_batch(
         self,

diff --git a/opentelemetry-sdk/tests/metrics/export/test_export.py b/opentelemetry-sdk/tests/metrics/export/test_export.py
@@ -139,8 +139,8 @@ def test_processor_process_exists(self):
         _batch_map[batch_key] = aggregator
         aggregator2.update(1.0)
         processor._batch_map = _batch_map
-        record = metrics.Record(metric, labels, aggregator2)
-        processor.process(record)
+        accumulation = metrics.Accumulation(metric, labels, aggregator2)
+        processor.process(accumulation)
         self.assertEqual(len(processor._batch_map), 1)
         self.assertIsNotNone(processor._batch_map.get(batch_key))
         self.assertEqual(processor._batch_map.get(batch_key).current, 0)
@@ -159,8 +159,8 @@ def test_processor_process_not_exists(self):
         batch_key = (metric, SumAggregator, tuple(), labels)
         aggregator.update(1.0)
         processor._batch_map = _batch_map
-        record = metrics.Record(metric, labels, aggregator)
-        processor.process(record)
+        accumulation = metrics.Accumulation(metric, labels, aggregator)
+        processor.process(accumulation)
         self.assertEqual(len(processor._batch_map), 1)
         self.assertIsNotNone(processor._batch_map.get(batch_key))
         self.assertEqual(processor._batch_map.get(batch_key).current, 0)
@@ -182,8 +182,8 @@ def test_processor_process_not_stateful(self):
         batch_key = (metric, SumAggregator, tuple(), labels)
         aggregator.update(1.0)
         processor._batch_map = _batch_map
-        record = metrics.Record(metric, labels, aggregator)
-        processor.process(record)
+        accumulation = metrics.Accumulation(metric, labels, aggregator)
+        processor.process(accumulation)
         self.assertEqual(len(processor._batch_map), 1)
         self.assertIsNotNone(processor._batch_map.get(batch_key))
         self.assertEqual(processor._batch_map.get(batch_key).current, 0)