Add integration test for distribution metric submission

Author: tianchu

tests/integration/api/test_api.py

@@ -33,6 +33,7 @@ def get_with_retry(
     else:
         resource = getattr(getattr(dog, resource_type), operation)(resource_id, **kwargs)
     retry_counter = 0
+    print(resource)
     while retry_condition(resource) and retry_counter < retry_limit:
         if resource_id is None:
             resource = getattr(getattr(dog, resource_type), operation)(**kwargs)
@@ -259,6 +260,25 @@ def retry_condition(r):
         assert len(metric_query_tuple["series"][0]["pointlist"]) == 1
         assert metric_query_tuple["series"][0]["pointlist"][0][1] == 1
 
+    def test_distribution_metrics(self):
+        now = datetime.datetime.now()
+        now_ts = int(time.mktime(now.timetuple()))
+        metric_name = "test.distribution_metric." + str(now_ts)
+        host_name = "test.host." + str(now_ts)
+
+        # Send metrics with single and multi points, and with compression
+        assert dog.Distribution.send(
+            distributions=[{
+                'metric': metric_name,
+                'points': [(now_ts - 60, [1.0])],
+                'type': 'distribution',
+                'host': host_name,
+            }]
+        )["status"] == "ok"
+
+        # FIXME: Query and verify the test metric result. Currently, it takes
+        # too long for a new distribution metric to become available for query.
+
     def test_graph_snapshot(self):
         metric_query = "system.load.1{*}"
         event_query = "*"