remove client from aggregator

datadog/dogstatsd/aggregator.py

@@ -8,8 +8,7 @@
 
 
 class Aggregator(object):
-    def __init__(self, client):
-        self.client = client
+    def __init__(self):
         self.metrics_map = {
             MetricType.COUNT: {},
             MetricType.GAUGE: {},
@@ -21,19 +20,6 @@ def __init__(self, client):
             MetricType.SET: threading.RLock(),
         }
 
-    def start(self, flush_interval):
-        self.flush_interval = flush_interval
-        self.client._start_flush_thread(flush_interval, self.send_metrics)
-
-    def stop(self):
-        self.client._stop_flush_thread(self.send_metrics)
-
-    def send_metrics(self):
-        for metric in self.flush_metrics():
-            self.client._report(
-                metric.name, metric.type, metric.value, metric.tags, metric.timestamp
-            )
-
     def flush_metrics(self):
         metrics = []
         for metric_type in self.metrics_map.keys():

tests/unit/dogstatsd/test_aggregator.py

@@ -1,14 +1,11 @@
 import unittest
-from mock import Mock
-from datadog.dogstatsd import DogStatsd
 from datadog.dogstatsd.metric_types import MetricType
 from datadog.dogstatsd.aggregator import Aggregator
 
 
 class TestAggregator(unittest.TestCase):
     def setUp(self):
-        self.client = Mock(spec=DogStatsd)
-        self.aggregator = Aggregator(self.client)
+        self.aggregator = Aggregator()
 
     def test_aggregator_sample(self):
         tags = ["tag1", "tag2"]