crux.tx — juxt/crux-core 19.09-1.5.0-alpha

*current-tx* clj

await-no-consumer-lag clj

(await-no-consumer-lag indexer timeout-ms)

await-tx-time clj

(await-tx-time indexer transact-time timeout-ms)

conform-tx-op clj multimethod

latest-completed-tx-time clj

(latest-completed-tx-time consumer-state)

log-tx-fn-error clj

(log-tx-fn-error fn-result fn-id body args-id args)

tx-command-cas clj

(tx-command-cas indexer
                kv
                object-store
                snapshot
                tx-log
                [op k old-v new-v at-valid-time :as cas-op]
                transact-time
                tx-id)

tx-command-delete clj

(tx-command-delete indexer
                   kv
                   object-store
                   snapshot
                   tx-log
                   [op k start-valid-time end-valid-time]
                   transact-time
                   tx-id)

tx-command-evict clj

(tx-command-evict indexer
                  kv
                  object-store
                  snapshot
                  tx-log
                  [op k start-valid-time end-valid-time keep-latest?
                   keep-earliest?]
                  transact-time
                  tx-id)

tx-command-fn clj

(tx-command-fn indexer
               kv
               object-store
               snapshot
               tx-log
               [op k args-v :as tx-op]
               transact-time
               tx-id)

tx-command-put clj

(tx-command-put indexer
                kv
                object-store
                snapshot
                tx-log
                [op k v start-valid-time end-valid-time]
                transact-time
                tx-id)

tx-command-unknown clj

(tx-command-unknown indexer
                    kv
                    object-store
                    snapshot
                    tx-log
                    [op k start-valid-time end-valid-time keep-latest?
                     keep-earliest?]
                    transact-time
                    tx-id)

tx-events->tx-ops clj

(tx-events->tx-ops snapshot object-store tx-events)

tx-fns-enabled? clj

tx-ops->docs clj

(tx-ops->docs tx-ops)

tx-ops->tx-events clj

(tx-ops->tx-events tx-ops)