dev.kwill.datomic-backup.impl — dev.kwill/datomic-backup 1.0.33

attr-value-type clj

(attr-value-type db attr)

bootstrap-datoms clj

(bootstrap-datoms db)

bootstrap-datoms-stop-tx clj

(bootstrap-datoms-stop-tx db)

conn? clj

(conn? x)

current-datom? clj

(current-datom? db datom)

datom-batch-tx-data clj

(datom-batch-tx-data source-db datoms source-eid->dest-eid lookup-dest-eid-fn)

datomic-internal-attrs clj

Idents managed by Datomic that should not be added to user-land schema.

datomic-schema-ident? clj

(datomic-schema-ident? k)

datum-reader clj

(datum-reader [e a v tx added])

filter-datoms-by-currently-existing clj

(filter-datoms-by-currently-existing db datoms)

filter-map->fn clj

(filter-map->fn db {:keys [include-attrs exclude-attrs]})

format-duration clj

(format-duration ms)

Format milliseconds as human-readable duration

get-old->new-ident-lookup clj

(get-old->new-ident-lookup db)

initial-eid-mapping clj

(initial-eid-mapping dest-db)

last-backed-up-tx-id clj

(last-backed-up-tx-id f)

max-tx-id-from-source clj

(max-tx-id-from-source source)

next-data clj

(next-data tx-report)

next-datoms-state clj

(next-datoms-state {:keys [source-eid->dest-eid db-before] :as acc}
                   source-db
                   datoms
                   lookup-dest-eid-fn
                   tx!)

next-file-state clj

(next-file-state acc datoms writer)

next-progress-report clj

(next-progress-report state progress cur-tx-id max-tx-id)

no-history-transform-fn clj

(no-history-transform-fn db remove-empty-transactions?)

q-datomic-internal-ident->eid clj

(q-datomic-internal-ident->eid db)

q-datomic-internal-source-eid->dest-eid clj

(q-datomic-internal-source-eid->dest-eid source-db dest-db)

q-last-tx clj

(q-last-tx db)

q-schema-lookup clj

(q-schema-lookup db)

read-edn-string clj

(read-edn-string s)

read-transactions-to-chan! clj

(read-transactions-to-chan! conn argm dest-ch)

Read transactions to a channel with retry and resumption. Similar to read-datoms-to-chan! but for transactions.

Parameters:

• conn: Datomic connection
• argm: Map with keys:
  • :start - Starting t or tx value (inclusive, optional)
  • :stop - Stopping t or tx value (exclusive, optional)
  • :xf - Transducer to apply to transaction datoms (optional)
• dest-ch: Channel to write transactions to

schema-result->lookup clj

(schema-result->lookup user-schema)

separator clj

t->tx clj

(t->tx conn t)

tempid clj

(tempid x)

tid-prefix clj

transactions-from-conn clj

(transactions-from-conn source-conn
                        {:keys [start stop transform-datoms timeout]})

transactions-from-file clj

(transactions-from-file reader
                        {:keys [transform-datoms]
                         :or {transform-datoms identity}})

transactions-from-source clj

(transactions-from-source source arg-map)

tuple-element-types clj

(tuple-element-types db attr)

Returns vector of value types for tuple elements, or nil if not a tuple. Handles three tuple variants:

• Composite (:db/tupleAttrs) - gets valueType of each constituent
• Heterogeneous (:db/tupleTypes) - returns explicit types
• Homogeneous (:db/tupleType) - repeats single type

tx->t clj

(tx->t conn tx)

tx-contains-only-tx-datoms? clj

(tx-contains-only-tx-datoms? txInstance-attr-eid datoms)

tx-instant-attr-id clj

(tx-instant-attr-id db)

with-timing clj macro

(with-timing & body)

Execute body and return [result elapsed-ms]

write-state-file! clj

(write-state-file! state-file {:keys [:source-eid->dest-eid :last-source-tx]})