datahike.writing — io.replikativ/datahike 0.6.1598

Manage all state changes and access to state of durable store.

branch-heads-as-commits clj

(branch-heads-as-commits store parents)

commit! clj

(commit! db parents)

(commit! db parents sync?)

complete-db-update clj

(complete-db-update old tx-report)

create-commit-id clj

(create-commit-id db)

create-database clj

(create-database)

(create-database config & opts)

database-exists? clj

(database-exists?)

(database-exists? config)

db->stored clj

(db->stored db flush?)

Maps memory db to storage layout. Index flushes will add [k v] pairs to pending-writes.

delete-database clj

(delete-database)

(delete-database config)

get-and-clear-pending-kvs! clj

(get-and-clear-pending-kvs! store)

Retrieves and clears pending key-value pairs from the store's pending-writes atom. Assumes :pending-writes in store's storage holds an atom of a collection of [key value] pairs.

load-entities clj

(load-entities old entities)

PDatabaseManager clj protocol

-create-database clj

(-create-database config opts)

-database-exists? clj

(-database-exists? config)

-delete-database clj

(-delete-database config)

stored->db clj

(stored->db stored-db store)

Constructs in-memory db instance from stored map value.

stored-db? clj

(stored-db? obj)

transact! clj

(transact! old {:keys [tx-data tx-meta]})

write-pending-kvs! clj

(write-pending-kvs! store kvs sync?)

Writes a collection of key-value pairs to the store. Handles synchronous and asynchronous writes. Assumes it's called within a go-try- block if sync? is false.