crux.checkpoint — juxt/crux-core 21.06-1.17.1-beta

->checkpointer clj

(->checkpointer opts)

->filesystem-checkpoint-store clj

(->filesystem-checkpoint-store {:keys [path]})

checkpoint clj

(checkpoint {:keys [dir src store :crux.checkpoint/cp-format approx-frequency]})

Checkpointer clj protocol

start clj

(start checkpointer src {:keys [:crux.checkpoint/cp-format]})

try-restore clj

(try-restore checkpointer dir cp-format)

CheckpointSource clj protocol

save-checkpoint clj

(save-checkpoint _ dir)

CheckpointStore clj protocol

available-checkpoints clj

(available-checkpoints store {:keys [:crux.checkpoint/cp-format]})

download-checkpoint clj

(download-checkpoint store checkpoint dir)

upload-checkpoint clj

(upload-checkpoint store dir {:keys [:crux.checkpoint/cp-format tx]})

cp-seq clj

(cp-seq start freq)

FileSystemCheckpointStore clj

recent-cp? clj

(recent-cp? {:crux.checkpoint/keys [checkpoint-at]} approx-frequency)

ScheduledCheckpointer clj