riemann receive consul events

gistfile1.txt

(defn consul-service-down-detect []
  (by [:host :service]
        (where (tagged "consul")                                                                                  
          (changed :state {:init "ok"}                                                                        
            (stable 300 :state                                                                                 
              #(info %)
              (where (not (state "ok"))                                                                        
                (tag "alert" #(info %) index)                                                                  
                (with :metric 1 (graph)))
              (where (state "ok")                                                                              
                (with :metric 0                                                                           
                  (graph))))))))