cloudwatch_riemann_2.clj

(defn tc [wndtime numwnds threshold & children]
  (fixed-event-window wndtime
     (combine folds/mean
         (moving-event-window numwnds
            (combine folds/minimum
               (where (> metric threshold)
                 ;;create a threshold crossing event
                 (with {:host nil  :state "threshold crossed" :description (str "service  crossed the value of " threshold " over " numwnds " windows of " wndtime " seconds")}
                   (apply sdo children)))))))
)

(streams

    (tc 3 3 6.0
       (email "[email protected]"))

)