Riemann PD Integration

(def pdalert
  (where (state "critical")
         (throttle 3 3600
                   (rollup 1 3600
                           (email "monitoring@gomycomp.org")))))

; PagerDuty Integration with Time Persistence threshold
(streams
  (stable (* 1 60) :state
          (let [pd (pagerduty "78e8bec940214cfa9905a1d01264de2de")]
            (changed-state
              (where (state "ok") (:resolve pd))
              (where (state "critical") (:trigger pd)))))
 )