feat(data_point): to_s == line protocol

place-labs · Dec 12, 2019 · 9e4828d · 9e4828d
1 parent 1397e7f
commit 9e4828d
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/spec/flux/data_point_spec.cr b/spec/flux/data_point_spec.cr
@@ -26,4 +26,14 @@ describe Flux::DataPoint do
       point.tags.should eq({:test => "bar"})
     end
   end
+
+  describe "to_s" do
+    it "serializes to line procotol" do
+      time = Time.now
+      ts = time.to_unix
+      point = Flux::DataPoint.new "foo", time, a: 1
+      point.tag :test, "bar"
+      point.to_s.should eq("foo,test=bar a=1 #{ts}\n")
+    end
+  end
 end
diff --git a/src/flux/data_point.cr b/src/flux/data_point.cr
@@ -1,3 +1,5 @@
+require "./line_protocol"
+
 # Model for InfluxDB data points.
 struct Flux::DataPoint
   alias TagSet = Hash(Symbol, String | Symbol)
@@ -31,4 +33,8 @@ struct Flux::DataPoint
   def tagged?
     !@tags.nil?
   end
+
+  def to_s(io)
+    LineProtocol.serialize self, io
+  end
 end