Riemann-ack hack

riemann-ack.config

;; -*- mode: Clojure; -*-

                                        ;(load-from-resource "/Users/pgautam/Projects/riemann-acknowledgement/target/riemann-acknowledgement-0.1.3.jar")
(include "../include")
(load-plugins)

(instrumentation {:interval 5
                  :enabled? false})

(let [host "0.0.0.0"]
  (tcp-server {:host host})
  (udp-server {:host host})
  (ws-server  {:host host})
  (repl-server  {:host host}))

(acknowledgement/acknowledgement-server)

(def mailout (let [m (mailer {:from "prasanna@mistsys.net"})]
               (m "prasanna@mistsys.net")))

(def disk-events-stream
  (where (and (service #"^disk /.*")
              (>= metric 0.8))
         (by [:host :service]
             ;; At most one alert per 10 minutes
             (tap :disk-slack-event
                  (acknowledgement/with-ack-status
                   slacker:testchannel)))))

(periodically-expire 10)

(let [index (index)]
  (streams
         (default :ttl 100)
         (acknowledgement/alert-stream prn index)
         #(info "Booyakasha" %)
         disk-events-stream
         ))