Merge pull request #3 from zgalor/add_post

Add post API call to post alerts

Author: zgalor

README.md

@@ -36,3 +36,8 @@ alerts = prometheus.get()
 \# get all the alerts with generation_id='12497ca8-b597-4590-ac5d-d55af7f3d185' and index >= 34
 
 alerts = prometheus.get(generation_id: '12497ca8-b597-4590-ac5d-d55af7f3d185', from_index: 34)
+
+#### Posting alerts
+\# post an alert JSON to server
+
+alerts = prometheus.post('{"alertId":12}')

examples/get_alerts.rb

@@ -1,7 +1,7 @@
 require 'prometheus/alert_buffer_client'
 
 # returns a client
-prometheus = Prometheus::AlertBufferClient::Client.new(url: 'http://localhost:9099', path: '/topics/zgalor')
+prometheus = Prometheus::AlertBufferClient::Client.new(url: 'http://localhost:9099', path: '/topics/test')
 
-alerts = prometheus.get(generation_id: '12497ca8-b597-4590-ac5d-d55af7f3d185', from_index: 5)
+alerts = prometheus.get(generation_id: '12497ca8-b597-4590-ac5d-d55af7f3d185', from_index: 1)
 puts alerts

examples/post_alerts.rb

@@ -0,0 +1,8 @@
+require 'prometheus/alert_buffer_client'
+
+# returns a client
+prometheus = Prometheus::AlertBufferClient::Client.new(url: 'http://localhost:9099', path: '/topics/test')
+
+prometheus.post '{"posted":"alert"}'
+prometheus.post '{"alertId":12}'
+

lib/prometheus/alert_buffer_client/client.rb

@@ -59,6 +59,16 @@ def get(options = {})
         JSON.parse(response.body)['messages']
       end
 
+      # post alert:
+      # @param [String] alert Alert to post
+      def post(alert)
+        @client.post do |req|
+          req.body = alert
+        end
+      rescue
+        raise RequestError, 'Bad response from server'
+      end
+
       # Helper function to evalueate the low level proxy option
       def faraday_proxy(options)
         return options[:proxy] if options[:proxy]