xtdb.checkpoint — com.xtdb/xtdb-core 1.24.0

->checkpointer clj

(->checkpointer opts)

->filesystem-checkpoint-store clj

(->filesystem-checkpoint-store {:keys [path no-colons-in-filenames?]})

apply-retention-policy clj

(apply-retention-policy {:keys [store :xtdb.checkpoint/cp-format
                                retention-policy]})

calculate-deleteable-checkpoints clj

(calculate-deleteable-checkpoints checkpoints
                                  {:keys [retain-newer-than retain-at-least]})

checkpoint clj

(checkpoint {:keys [dir bus src store :xtdb.checkpoint/cp-format
                    approx-frequency]
             :as checkpoint-opts})

Checkpointer clj protocol

start clj

(start checkpointer src {:keys [:xtdb.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 [:xtdb.checkpoint/cp-format]})

cleanup-checkpoint clj

(cleanup-checkpoint store {:keys [:xtdb.checkpoint/cp-format cp-at tx]})

download-checkpoint clj

(download-checkpoint store checkpoint dir)

upload-checkpoint clj

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

cp-exists-for-tx? clj

(cp-exists-for-tx? cp {:keys [:xtdb.api/tx-id] :as tx})

cp-seq clj

(cp-seq start freq)

format-fs-date clj

(format-fs-date {:keys [no-colons-in-filenames?]} date)

recent-cp? clj

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

validate-retention-policy clj

(validate-retention-policy {:keys [retention-policy]})