kafka-clj.redis.core — kafka-clj 4.0.3

acquire-lock clj

(acquire-lock pool lock-name timeout-ms wait-ms)

add-host-port clj

(add-host-port conf server)

Take server and see if its host:port add (assoc conf :host (host server) :port (server)) else (assoc conf :host server)

brpoplpush clj

(brpoplpush pool queue queue2 n)

close! clj

(close! pool)

conn-pool-active clj

(conn-pool-active pool)

conn-pool-idle clj

(conn-pool-idle pool)

create clj

(create redis-conf)

{:host []} use cluster {:host ""} :or {:host [v1]} use single

create-cluster-conn clj

(create-cluster-conn redis-conf)

create-single-conn clj

(create-single-conn redis-conf)

flushall clj

(flushall pool)

get clj

(get pool k)

have-lock? clj

(have-lock? pool lock-name owner-uuid)

llen clj

(llen pool queue)

lpush clj

(lpush pool queue obj)

lpush* clj

(lpush* pool queue obj-coll)

lrange clj

(lrange pool q n limit)

lrem clj

(lrem pool queue n obj)

lua clj

(lua pool script-str)

redis-cluster-conn clj

(redis-cluster-conn cluster-conf)

Creates a redis connection for a redis cluster

redis-conn clj

(redis-conn spec opts)

Creates a redis connection for a single redis instance

release-lock clj

(release-lock pool lock-name owner-uuid)

set clj

(set pool k v)

wcar clj macro

(wcar pool & body)

with-lock clj macro

(with-lock pool lock-name timeout-ms wait-ms & body)

Attempts to acquire a distributed lock, executing body and then releasing lock when successful. Returns {:result <body's result>} on successful release, or nil if the lock could not be acquired. If the lock is successfully acquired but expires before being released, throws an exception.