 
 (defn shutdown-log-path [prefix]
   (str root-path "/" prefix "/coordinator/shutdown-log"))
+
+(defn with-checkpoint-path [path]
+  (str path "/checkpoint"))
 
 (defrecord ZooKeeper [opts]
   component/Lifecycle

      (zk/create-all conn (complete-log-path) :persistent? true)
      (zk/create-all conn (shutdown-log-path) :persistent? true)

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

  (stop [component]

  (create-log-entry sync shutdown-log-path content))

(defn checkpoint-log [sync f n]
  (let [checkpoint (str (f) "/checkpoint")
        cp (extensions/read-node sync checkpoint)]
    (extensions/write-node sync checkpoint (inc (or cp 0)))))

(defmethod extensions/checkpoint [ZooKeeper :born-log]
  [sync _ n]
