gistfile1.txt

; -*- 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}))

; Expire old events from the index every 5 seconds.
(periodically-expire 10 {:keep-keys [:host :service :tags :metric]})

(def email (mailer {:from "[email protected]"}))
(def pd (pagerduty "a9d4031c77a643818323fb6f1fab0684"))
(def graph (graphite {:host "localhost"}))

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

      (changed-state {:init "ok"}
        (stable 60 :state
          (where (state "ok") (:resolve pd))
          (where (state "expired") (:trigger pd)))))))

; graph all
  (streams
    graph)

; print events to the log
  (streams
      prn

      #(info %))