(let [index (index)]
  (streams
    (default :ttl 60
      index

    (tagged "collectd"
        (smap rewrite-service graph

        (by [:host :service]
            (where (or (service "cpu/percent-idle") (service #"^ping-droprate.*"))
                    #(info "BEFORE STABLE" (:host %) (:service %) "METRIC" (:metric %) "###" (:state %))
                    (stable 180 :state
                    #(info "STABLE" (:host %) (:service %) "METRIC" (:metric %) "###" (:state %))
                        (changed-state {:init "ok"}
                        #(info "CHANGED-STATE" (:host %) (:service %) (:metric %) (:state %))
                        (throttle 50 3600
                            (with :description "from monitor"
                            (telegram {:token token :chat_id chat_id})))))))))
                                                )))