event-data-common.storage.redis — event-data-common 0.1.57

Storage interface for redis. Provides two interfaces: RedisStore which conforms to Store, and Redis, which contains Redis-specific methods. RedisStore satisfies the event-data-common.storage.storage.Store protocol. All keys are stored in Redis with the given prefix.

add-prefix clj

(add-prefix prefix k)

build clj

(build prefix host port db-number)

Build a RedisConnection object.

get-connection clj

(get-connection pool db-number)

Get a Redis connection from the pool. Must be closed.

make-jedis-pool clj

(make-jedis-pool host port)

Redis clj protocol

Redis-specific interface.

expiring-mutex!? clj

(expiring-mutex!? this k milliseconds)

Check and set expiring mutex atomically, returning true if didn't exist.

incr-key-by!? clj

(incr-key-by!? this k value)

Set and return incremented Long value.

expire-seconds! clj

(expire-seconds! this k seconds)

Set expiry in seconds.

subscribe-pubsub clj

(subscribe-pubsub this channel callback)

Register callback for PubSub channel and block thread.

set-add clj

(set-add this k value)

Add a value to a set.

publish-pubsub clj

(publish-pubsub this channel value)

Broadcast over PubSub

sorted-set-increment clj

(sorted-set-increment this k kk value)

Increment the field of a sorted set by the value.

sorted-set-members clj

(sorted-set-members this k)

Return all members of the sorted set with their values.

set-string-and-expiry clj

(set-string-and-expiry this k v milliseconds)

Set string value with expiry in milliseconds.

sorted-set-put clj

(sorted-set-put this k member value)

Set the field of the sorted set to have the value.

set-string-and-expiry-seconds clj

(set-string-and-expiry-seconds this k v seconds)

Set string value with expiry in seconds.

set-members clj

(set-members this k)

Return all members from a set.

remove-prefix clj

(remove-prefix prefix-length k)

scan-match-cursor clj

(scan-match-cursor connection pattern cursor)

Lazy sequence of scan results matching pattern.

sscan-cursor clj

(sscan-cursor connection k cursor)

Lazy sequence of sscan (set scan) results.

zscan-cursor clj

(zscan-cursor connection k)

Return a realized map of {set-member score}