selfcleanup.clj

(defrecord GHCache [^TTLCache ttl-cache etagged cleaner-c])

(defn init-cache []
  (let [control-c (chan)
        old-killer (fn [etagged]
                     (let [now (System/currentTimeMillis)]
                       (->> etagged
                            (filter #(> (- now (-> % value :created-at))
                                        (* 6 60 60 1000)))
                            (into {}))))
        cache (GHCache. (atom (cache/ttl-cache-factory {} :ttl (* 60 1000)))
                        (atom {})
                        (go (let [this (<! control-c)]
                              (loop []
                                (<! (timeout (* 6 60 60 1000)))
                                (swap! (:etagged this) old-killer)
                                (recur)))))]
    (>!! control-c cache)
    cache))