ozjongwon.dynotx — com.ozjongwon/dynohub 1.1.0

Clojure DynamoDB Transaction - idea from https://github.com/awslabs/dynamodb-transactions

*current-txid* clj

+pending+ clj

+state+ clj

pending -> commited or rolled-back

+txid+ clj

Primary key, UUID

apply-request-op clj multimethod

commit clj

(commit txid)

delete clj

(delete txid)

(delete txid timeout)

delete-item clj

(delete-item table
             prim-kvs
             &
             {:keys [return expected return-cc? txid txid]
              :or {return :none txid *current-txid*}
              :as opts})

dynotx.defn clj macro

(dynotx.defn op [table & args] & body)

ensure-transaction clj

(ensure-transaction)

get-item clj

(get-item table prim-kvs & {:keys [attrs consistent? return-cc? txid] :as opts})

get-tx-item clj

(get-tx-item txid)

init-tx clj

(init-tx & opts)

item-with-proper-return-value clj multimethod

make-request-for-dynotx-defn clj multimethod

make-transaction clj

(make-transaction)

(make-transaction tx-id-or-item)

Make a new transaction. Transaction = tx-item + fully-applied-request-versions

prim-kvs clj multimethod

put-item clj

(put-item table
          item
          &
          {:keys [return expected return-cc? txid] :or {return :none} :as opts})

rollback clj

(rollback txid)

sweep clj

(sweep txid rollback-timeout delete-timeout)

table-keys clj

tx-map clj

txid->tx clj

(txid->tx txid)

unlock-item-after-commit-using-op clj multimethod

update-item clj

(update-item table
             prim-kvs
             update-map
             &
             {:keys [return expected return-cc? txid]
              :or {return :none txid *current-txid*}
              :as opts})

with-opts-prim-keys-expected clj macro

(with-opts-prim-keys-expected [[opts expected] request] & body)

with-transaction clj macro

(with-transaction [& txid-var] & body)

with-tx-attributes clj macro

(with-tx-attributes [] & body)

with-updating-tx-map-on-success clj macro

(with-updating-tx-map-on-success
  [& {:keys [transformer] :or {transformer (quote clojure.core/identity)}}]
  &
  body)