Merge pull request #20 from tverlaan/timestamping-and-batch-sending

batch sending of multiple values with timestamping enabled
travelping · Apr 1, 2016 · 072bbfb · 072bbfb
2 parents d837ba3 + 3e64c82
commit 072bbfb
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/exometer_report_influxdb.erl b/src/exometer_report_influxdb.erl
@@ -264,6 +264,11 @@ maybe_send(OriginMetricName, MetricName, Tags0, Fields,
             maps:put(OriginMetricName, 
                      {MetricName, Tags, NewFields, Timestamping andalso unix_time(Precision)}, 
                      CollectedMetrics);
+        {MetricName, Tags, Fields1, _OrigTimestamp} ->
+            NewFields = maps:merge(Fields, Fields1),
+            maps:put(OriginMetricName,
+                     {MetricName, Tags, NewFields, Timestamping andalso unix_time(Precision)},
+                     CollectedMetrics);
         not_found -> 
             maps:put(OriginMetricName, 
                      {MetricName, Tags0, Fields, Timestamping andalso unix_time(Precision)},