difo.redis — difo 0.1.0

connection clj

dequeue clj

(dequeue from)

enqueue clj

(enqueue into unit)

enumerate-difo-processes clj

(enumerate-difo-processes)

enumerate-workers-keys clj

(enumerate-workers-keys)

get-worker clj

(get-worker id)

key-name clj

last-housekeeping-timestamp clj

(last-housekeeping-timestamp)

list-workers clj

(list-workers)

new-raft-listener clj

(new-raft-listener f)

notify-current-unit clj

(notify-current-unit worker unit)

publish-raft clj

(publish-raft message)

record-failed-unit clj

(record-failed-unit worker)

record-processed-unit clj

(record-processed-unit worker)

register-heartbeat clj

(register-heartbeat worker)

register-process clj

(register-process node)

remove-key clj

(remove-key & keys)

remove-worker clj

(remove-worker id)

stop-raft-listener clj

(stop-raft-listener listener)

unregister-process clj

(unregister-process node)

with-connection clj macro

(with-connection & body)