molecula.transaction — molecula 0.1.4

*t* clj

->transaction clj

(->transaction conn)

CFn clj

commit clj

(commit retries)

Returns:

• nil if everything went ok
• an error "object" if anything went wrong

commute-ref clj

(commute-ref rk)

Applies all ref's commutes starting with ref's oldval

dispatch-agents clj

(dispatch-agents)

do-commute clj

(do-commute ref f args)

do-ensure clj

(do-ensure ref)

do-get clj

(do-get ref)

do-set clj

(do-set ref value)

notify-watches clj

(notify-watches)

(notify-watches rks)

Notifies watches on all updatables given the latest oldval and latest tval

RETRY_LIMIT clj

run clj

(run f)

run-in-transaction clj

(run-in-transaction conn f)

running? clj

(running?)

tconn clj

(tconn)

tcontains? clj

(tcontains? op rk)

tget clj

(tget & ks)

throw-when-nil-t clj

(throw-when-nil-t)

Throws IllegalStateException if t is nil. Returns nil otherwise. This is equivalent to clojure.lang.LockingTransaction/getEx() Used in RedisRef to guard methods from being called outside transaction.

tput-commute! clj macro

(tput-commute! rk cfn)

tput-ensure! clj macro

(tput-ensure! rk)

tput-oldval! clj macro

(tput-oldval! rk oldval)

tput-ref! clj macro

(tput-ref! ref)

tput-set! clj macro

(tput-set! rk)

tput-tval! clj macro

(tput-tval! rk tval)

updatables clj

(updatables)

Returns a set of refs that have been altered or commuted

validate clj

(validate)

(validate rks)

Validates all updatables given the latest tval

validate* clj

(validate* vf val)

This is a clojure re-implementation of clojure.lang.ARef/validate because it cannot be accessed by subclasses. It is needed to invoke when changing ref state