 ;; TODO: tracking needs to be reviewed
 ;; TODO: display of events
 ;; TODO: per message vs per batch error handling
+;; TODO: handling of events which not match any route
 ;;
 
 

   []))


(defn local-kv-restore
  "Takes a bunch of tx-log events and restores them in the stream loca-stores"
  ([{:keys [component stream-id events]}]
   (let [kv-store (:local-store (stream-config component stream-id))]
     (var-set kv-store

(ns samsara-core.kernel2
  (:refer-clojure :exclude [var-get var-set])
  (:require [clojure.string :as str]
            [com.stuartsierra.component :as component]
            [moebius
             [core :refer [where inject-if]]
             [kv :as kv]]
            [samsara.utils :refer [from-json to-json]]
            [taoensso.timbre :as log])
  (:require [samsara.trackit :refer [track-time track-rate new-registry
                                     count-tracker distribution-tracker
                                     track-pass-count] :as trk]))


;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
