; -*- mode: clojure; -*-
; vim: filetype=clojure

(logging/init {:file "/var/log/riemann/riemann.log"})

; Listen on the local interface over TCP (5555), UDP (5555), and websockets
; (5556)
(let [host "0.0.0.0"]
(tcp-server {:host host})
(udp-server {:host host})
(ws-server  {:host host}))
(instrumentation {:enabled? false})


; Expire old events from the index every 5 seconds.
(periodically-expire 5)

(use '[clojure.java.shell :only [sh]])

(let [index (index)]
; Inbound events will be passed to these streams:
 (streams
  (default :ttl 180
    ; Index all events immediately.
    ;index
    (by [:host :service]

      (where (and (and (host "riemann-health-m1") (service "load")) (>= metric 0.3) )
         (sh "bash" "-c" "/etc/riemann/test.sh ")
         prn)
         ; index
         ; (with service "load" (sh "bash" "-c" "/etc/riemann/test.sh"))
         ; (else
         ; (with :service "cpu" index))
          ; index)
         ; )
      (where  (host "riemann-health-m2")
         (with :service "load" index))
      (where  (host "riemann-health-m3")
         (with :service "cpu" index)))

    ; Log expired events.
    (expired
      (fn [event] (info "expired" event))))))