 (defn job-log-path [prefix]
   (str root-path "/" prefix "/job-log"))
 
-
-
 (defn born-log-path [prefix]
   (str root-path "/" prefix "/coordinator/born-log"))
 

      (zk/create conn (job-path prefix) :persistent? true)
      (zk/create conn (job-log-path prefix) :persistent? true)

      (assoc component :server server :conn conn :prefix (:onyx/id opts))))

  (stop [component]

(defn shutdown-log-path [prefix]
  (str root-path "/" prefix "/coordinator/shutdown-log"))

(defrecord ZooKeeper [opts]
  component/Lifecycle

  (start [component]
    (taoensso.timbre/info "Starting ZooKeeper")
    (let [server (when (:zookeeper/server? opts) (TestingServer. (:zookeeper.server/port opts)))
          conn (zk/connect (:zookeeper/address opts))
          prefix (:onyx/id opts)]
      (zk/create conn root-path :persistent? true)
