queue-monitoring.clj

queue-monitoring.clj

(defn- queue-stuck?
  [events]
  (comment "простейшая проверка, что очередь не стала меньше"))

(defn- make-alert-event
  [events]
  (merge (first events) { :state "major" :description (str "Смотрите как все плохо " events)}))

(defn- when-stuck
  [children]
  (fn [events]
    (if queue-stuck?(events)
      (call-resque make-alert-event(events) children))))



(let [queue-monitoring
      (tagged "queues-monitor"
              (by [:service :host]
                  (moving-time-window 300
                                      (queue-monitoring/when-stuck tell-ops))))]

  (streams
   (io #(info "New event" %))
   queue-monitoring))