clj-faktory.core — tech.ducktype/clj-faktory 0.2.15

ack clj

(ack conn-pool jid)

beat clj

(beat conn-pool wid)

conn-pool clj

fail clj

(fail conn-pool jid e)

fetch clj

(fetch conn-pool queues)

info clj

(info {:keys [conn-pool]})

perform-async clj

(perform-async worker-manager job-type args)

(perform-async {:keys [prio-pool]} job-type args opts)

push clj

(push conn-pool job)

register-job clj

(register-job job-type handler-fn)

start clj

(start {:keys [worker-pool concurrency] :as worker-manager})

stop clj

(stop {:keys [conn-pool prio-pool worker-pool :as worker-manager]})

transit-args? clj

(transit-args? args)

worker-manager clj

(worker-manager conn-pool)

(worker-manager conn-pool
                {:keys [concurrency heartbeat queues]
                 :or {concurrency 10 heartbeat 10000 queues ["default"]}})