added FnordMetric::UDPClient

Vaysman · May 6, 2012 · e0c0cbe · e0c0cbe
1 parent b20241d
commit e0c0cbe
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/lib/fnordmetric.rb b/lib/fnordmetric.rb
@@ -147,6 +147,7 @@ def self.embedded(opts={})
 end
 
 require "fnordmetric/api"
+require "fnordmetric/udp_client"
 require "fnordmetric/inbound_stream"
 require "fnordmetric/worker"
 require "fnordmetric/widget"

diff --git a/lib/fnordmetric/udp_client.rb b/lib/fnordmetric/udp_client.rb
@@ -0,0 +1,22 @@
+class FnordMetric::UDPClient
+
+  def initialize(host, port)
+    @sock = UDPSocket.new
+    @sock.connect(host, port)
+  end
+
+  def event(event_data)
+    begin
+      if event_data.is_a?(Hash)
+        event_data = event_data.to_json
+      else
+        JSON.parse(event_data) # void ;)
+      end
+    rescue JSON::ParserError
+      FnordMetric.log("event_lost: can't parse json")
+    else
+      @sock.send(event_data, 0)
+    end
+  end
+
+end