lib.redis.event

+actions+

+default+

+lu+

+rlu+

action:add

added in 3.0

(action:add key {:keys [subscribe unsubscribe args wrap], :as m})

adds an action from registry

action:get

added in 3.0

(action:get key)

gets action type

action:list

added in 3.0

(action:list)

lists action types

action:remove

added in 3.0

(action:remove key)

removes an action from registry

config:add

added in 3.0

(config:add redis events)(config:add redis events opts)

adds config notifications

config:get

added in 3.0

(config:get redis)(config:get redis opts)

gets the config for notifications

config:remove

added in 3.0

(config:remove redis events)(config:remove redis events opts)

removes config notifications

config:set

added in 3.0

(config:set redis events)(config:set redis events opts)

sets the config for notifications

events-parse

added in 3.0

(events-parse s)

creates a set of enums from a string

events-string

added in 3.0

(events-string events)

creates a string from a set of enums

has-notify

added in 3.0

(has-notify redis id)

checks that a given notify listener is installed

list-notify

added in 3.0

(list-notify redis)

lists all notify listeners for a client

listener-loop

added in 3.0

(listener-loop conn f)

creates a listener loop

listener-string

added in 3.0

(listener-string {:keys [type connection], :as listener})

string description of a listener

listener:add

added in 3.0

(listener:add type redis id input handler)(listener:add type {:keys [namespace runtime pool], :as redis} id input handler opts)

adds a listener to the redis client

listener:all

added in 3.0

(listener:all {:keys [runtime]})

lists all listeners

listener:count

added in 3.0

(listener:count {:keys [runtime]})

counts all listeners

listener:create

added in 3.0

(listener:create {:keys [namespace pool], :as redis} type id input handler)

creates a listener

listener:get

added in 3.0

(listener:get {:keys [runtime]} type id)

gets a client listener

(-> (doto |client| (subscribe :foo “foo” prn)) (listener:get :subscribe :foo)) => listener?

listener:list

added in 3.0

(listener:list {:keys [runtime]})

lists all listeners

(-> (doto |client| (subscribe :foo “foo” prn) (psubscribe :bar “*” prn)) (listener:list)) => {:subscribe :foo :psubscribe :bar}

listener:remove

added in 3.0

(listener:remove type {:keys [runtime], :as redis} id)

removes a listener from the client

listener:teardown

added in 3.0

(listener:teardown {:keys [type connection], :as listener})

tears down the listener

listener?

added in 3.0

(listener? obj)

checks that object is a listener

notify

added in 3.0

(notify redis id pattern handler)

notifications for a given client

notify:args

added in 3.0

(notify:args namespace inputs)

produces the notify args

notify:wrap

added in 3.0

(notify:wrap handler {:keys [namespace], :as redis})

wrapper for the notify delivery function

psubscribe

added in 3.0

(psubscribe redis id pattern handler)

subscribes to a pattern on the cache

psubscribe:wrap

added in 3.0

(psubscribe:wrap handler {:keys [format], :as redis})

wrapper for the psubscribe delivery function

punsubscribe

added in 3.0

(punsubscribe redis id)

unsubscribes from the pattern

start:events-redis

added in 3.0

(start:events-redis redis events)

creates action for :events

start:notify-redis

added in 3.0

(start:notify-redis redis listeners)

creates action for :notify

stop:notify-redis

added in 3.0

(stop:notify-redis redis listeners)

stop action for :notify field

subscribe

added in 3.0

(subscribe redis id channels handler)

subscribes to a channel on the cache

subscribe:wrap

added in 3.0

(subscribe:wrap handler {:keys [format], :as redis})

wrapper for the subscribe delivery function

unnotify

added in 3.0

(unnotify redis id)

removes notifications for a given client

unsubscribe

added in 3.0

(unsubscribe redis id)

unsubscribes from a channel