(await-no-consumer-lag indexer
{:crux.tx-log/keys [await-tx-timeout]
:or {await-tx-timeout default-await-tx-timeout}})
(await-tx-time indexer
transact-time
{:crux.tx-log/keys [await-tx-timeout]
:or {await-tx-timeout default-await-tx-timeout}})
(enrich-tx-ops-with-documents snapshot object-store tx-ops)
(evicted-doc? doc)
(latest-completed-tx-time consumer-state)
(start-event-log-consumer event-log-kv indexer event-log-sync-interval-ms)
(tx-command-cas object-store
snapshot
tx-log
[op k old-v new-v at-valid-time :as cas-op]
transact-time
tx-id)
(tx-command-delete object-store
snapshot
tx-log
[op k start-valid-time end-valid-time]
transact-time
tx-id)
(tx-command-evict object-store
snapshot
tx-log
[op k start-valid-time end-valid-time keep-latest?
keep-earliest?]
transact-time
tx-id)
(tx-command-put object-store
snapshot
tx-log
[op k v start-valid-time end-valid-time]
transact-time
tx-id)
(tx-command-unknown object-store
snapshot
tx-log
[op k start-valid-time end-valid-time keep-latest?
keep-earliest?]
transact-time
tx-id)
(tx-ops->docs tx-ops)
(tx-ops->tx-events tx-ops)
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close