Monitoring a Graph

graph_monitoring.clj

(defn observe-graph [g record-node-time!]
  (into {}
   (for [[k f] g]
    [k
     (with-meta
       (fn [m]
         (let [t0 (System/nanoTime)
               v (f m)
               t1 (System/nanoTime)]
           (record-node-time! k (- t1 t0))
           v))
       (meta f))])))

(def observed-stats 
  (graph/eager-compile
    (observe-graph stats-graph record-to-dashboard!)))