kafka-clj.redis.cluster — kafka-clj 4.0.3

acquire-lock clj

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

as-array clj

(as-array v)

brpoplpush clj

(brpoplpush cmd queue1 queue2 timeout)

close! clj

(close! cmd)

codec clj

(codec)

connect clj

(connect redis-conf)

create clj

(create redis-conf)

create-config clj

(create-config redis-conf)

create-sentinal-config clj

(create-sentinal-config redis-conf)

flushall clj

(flushall cmd)

from-bytes clj

(from-bytes bts)

get clj

(get cmd k)

have-lock? clj

(have-lock? cmd lock-name lock)

IAsStr clj protocol

-as-str clj

(-as-str obj)

IToEncodedBytes clj protocol

-write clj

(-write obj)

IToRawBytes clj protocol

-raw-bytes clj

(-raw-bytes obj)

llen clj

(llen cmd queue)

lpush clj

(lpush cmd queue v)

lrange clj

(lrange cmd queue n limit)

lrem clj

(lrem cmd queue n v)

lua clj

(lua cmd script-str)

nippy-decoder clj

(nippy-decoder)

nippy-encoder clj

(nippy-encoder)

nippy-map-key-decoder clj

(nippy-map-key-decoder)

nippy-map-key-encoder clj

(nippy-map-key-encoder)

pop-retry clj

(pop-retry cmd timeout)

release-lock clj

(release-lock cmd lock-name lock)

set clj

(set cmd k v)

timeout? clj

(timeout? start-time timeout)