; Integration of PAgerDuty
(def pdalert
  (where (state "critical")
    (throttle 3 3600
      (rollup 1 3600
            (email "monitoring@mycompa.org")))))
; TODO Add throttle and rollup here to avoid flooding PD
(streams
        (let [pd (pagerduty "77adbec940214gde5505a1d017925b99")]
          (changed-state
            (where (state "ok") (:resolve pd))
            (where (state "critical") (:trigger pd))))
                pdalert)