(streams
  (stream {:name :multiple_branches :description "Example configuration"}
    (where [:= :service "http_request_duration_seconds"]
      (with :ttl 60
        ;; push everything into influxdb
        (push-io! :influxdb)
        ;; index events in memory by host and service
        (index [:host :service])
        ;; by will generate a branch for each :host value. Like that, downstream
        ;; computations will be per host and will not conflict between each other
        (by [:host]
          ;; if the metric is greater than 1 for more than 60 seconds
          ;; Pass events downstream
          (above-dt {:duration 60 :threshold 1}
            ;; pass the state to critical
            (with :state "critical"
              ;; one alert only every 60 sec to avoid flooding pagerduty
              (throttle {:duration 60 :count 1}
                (push-io! :pagerduty)))))))))

(streams

 (stream {:name :main :default true :description "All events will arrive into this stream"}
   ;; inject events into the :alert and :influxdb streams
   (reinject! :alert)
   (reinject! :influxdb))

 (stream {:name :alert :description "Send alerts to pagerduty"}
   ;; keep only critical events
   (critical
     ;; split the actions by host/service
     (by [:host :service]
       ;; let only one event pass every 60 sec
       (throttle {:duration 60 :count 1}
         ;; send to pagerduty
         (push-io! :pagerduty)))))

 (stream {:name :influxdb :description "Send all events to InfluxDB"}
   ;; handle influxdb errors
   (exception-stream
     ;; set the :source key to "mirabelle"
     (with :source "mirabelle"
       ;; push to influxdb
       (push-io! :influxdb))
       ;; set the :service key to "mirabelle-influxdb-error"
     (with :service "mirabelle-influxdb-error"
       ;; inject events into the :alert stream
       (reinject! :alert)))))