gistfile1.txt

(defonce ^{:private true} running-hosts (agent {}))
(defn- update-running-hosts
  "Update the running-hosts agent with new set of hosts from AWS"
  [curr]
  (let [hosts (clojure.string/split-lines
               (run "scripts/print-running-hosts"))]
    (loop [newhosts (remove curr hosts)
           nxt      curr]
      (if (empty? newhosts)
        nxt
        (let [host       (first newhosts)
              tailer     (register-log-source host (server-log-tail-f host))]
          (println "Added new host: " host)
          (recur (next newhosts)
                 (assoc nxt host tailer)))))))

(defonce ^{:private true} running-components (agent {}))
(defn- update-running-components
  "Update the running components in the cloud"
  [agt]
  (let [comps (cloud/components-logs cloud/sandbox)]
    (reduce (fn [newagt comp]
              (if (newagt comp)
                newagt
                (assoc newagt comp (register-log-source (comps comp)))))
            newagt
            (keys comps))))