Closes and de-registers! all listeners belonging to mp-id .

Clears the key x. If x is a vector the function stu/vec->key is used for the conversion of x to a string.

Closes the given listener generated by gen-listener.

Example:

;; generate
(def l (gen-listener "ref" "ctrl" msg->key))
;; close 
(close-listener! l)

De-registers the listener with the key mp-id in the listeners atom.

Delets the key k.

Deletes all given keys (ks).

Returns a list of all keys belonging to the pattern pat where the value is equal tox.

Example:

(filter-keys-where-val "ref@definitions@*@class" "wait")
;; ("ref@definitions@0@class"
;; "ref@definitions@2@class"
;; "ref@definitions@1@class")

Returns a listener for published keyspace notifications. Don’t forget to close-listener!

Example:

;; generate and close
(close-listener! (gen-listener "ref" "ctrl" msg->key))

Get all keys matching k*.

Returns the value for the given key (k) and cast it to a clojure type.

Returns a vector of the vals behind the keys ks.

Extracts the key from a published keyspace notification message (pmessage).

Example:

(def msg ["pmessage"
         "__keyspace@0*__:ref@*@*@ctrl*"
         "__keyspace@0__:ref@container@0@ctrl"
         "set"])
(st/msg->key msg)
;; "ref@container@0@ctrl"

Get all keys matching the given pattern pat.

Generates a registration key for the listener atom. The level param allows to register more than one listener for one pattern.

Generates and registers a listener under the key mp-id in the listeners atom. The cb! function dispatches depending on the result.

Checks if a listener is registered under the listeners-atom.

Sets the given val for all keys ks with the delay mtp.

Function is used by the workers to set state. An optional log message may be provided.

Sets the value v for the key k.

Generates subscribe patterns which matches depending on:

l2

• container
• definitions

l3

• 0 … n

l4

• ctrl
• state
• definition