roomkey.znode — com.roomkey/drcfg 7.1.0

A facade for a Zookeeper znode

add-descendant clj

(add-descendant parent path value)

Add a descendant ZNode to the given parent's (sub)tree root ZNode at the given (relative) path carrying the given value creating placeholder intermediate nodes as required.

BackedZNode clj protocol

A Proxy for a ZooKeeper znode

compare-version-and-set! clj

(compare-version-and-set! this current-version new-value)

Atomically set the value of this znode to new-value if and only if the current version is identical to current-version. Returns true if set happened, else false

create! clj

(create! this)

Create the znode backing this virtual node

delete! clj

(delete! this version)

Delete this znode, asserting the current version

watch clj

(watch this)

Recursively watch the znode and its children, returning a WatchManager that can be closed to cease watching, read from to get the results of watching and, as seq'd, to obtain the WatchManagers of its children

default clj

(default client path)

(default client path value)

new-root clj

(new-root)

(new-root abs-path)

(new-root abs-path value)

(new-root abs-path value zclient)

Create a root znode

open clj

(open root & args)

Open a ZooKeeper client connection and watch for client status changes to manage watches on root and its descendants

VirtualNode clj protocol

A value-bearing node in a tree

overlay clj

(overlay this v)

Overlay the existing placeholder node's value with a concrete value

signature clj

(signature this)

Return a (Clojure) hash equivalent to a signature of the state of the subtree at this ZNode

update-or-add-child clj

(update-or-add-child this path value)

Update the existing child or create a new child of this node at the given path & with the given default value

walk clj

(walk connect-string timeout xform f init)

Walk the tree defined by connect-string and transduce the asynchronously discovered nodes with xform and f.

with-connection clj macro

(with-connection znode connect-string timeout & body)