cljobq.job — cljobq 0.1.5

dbjob->friendly-job clj

(dbjob->friendly-job dbjob)

delete-and-fail-job! clj

(delete-and-fail-job! db {:keys [id]})

delete-failed-job-by-id! clj

(delete-failed-job-by-id! db {:keys [id]})

delete-job! clj

(delete-job! db {:keys [id]})

delete-job-by-name! clj

(delete-job-by-name! db {:keys [queue job-name]})

delete-queue-jobs! clj

(delete-queue-jobs! db {:keys [queue]})

get-failed-job-by-id clj

(get-failed-job-by-id db {:keys [id]})

get-failed-jobs clj

(get-failed-jobs db)

get-failed-jobs-by-queue clj

(get-failed-jobs-by-queue db {:keys [queue]})

get-job-by-id clj

(get-job-by-id db {:keys [id]})

get-job-by-name clj

(get-job-by-name db {:keys [queue job-name]})

get-job-stats clj

(get-job-stats db)

get-jobs clj

(get-jobs db)

get-jobs-by-queue clj

(get-jobs-by-queue db {:keys [queue]})

get-jobs-with-error clj

(get-jobs-with-error db)

get-queue-stats clj

(get-queue-stats db)

get-recurring-jobs clj

(get-recurring-jobs db)

get-stats clj

(get-stats db)

(get-stats db queue)

identifiers clj

(identifiers x)

inc-queue-fail! clj

(inc-queue-fail! db {:keys [queue retries]})

inc-queue-success! clj

(inc-queue-success! db {:keys [queue retries]})

insert-job! clj

(insert-job! db {:keys [queue job-name actor payload interval run-at]})

list-failed-jobs clj

(list-failed-jobs db)

(list-failed-jobs db queue)

list-jobs clj

(list-jobs db)

(list-jobs db queue)

list-queue-names clj

(list-queue-names db)

list-recurring-jobs clj

(list-recurring-jobs db)

(list-recurring-jobs db queue)

pick-job-by-queue! clj

(pick-job-by-queue! db {:keys [queue base-timeout backoff-factor max-timeout]})

reenqueue-and-fail-job! clj

(reenqueue-and-fail-job! db {:keys [id run-at]})

reenqueue-job! clj

(reenqueue-job! db {:keys [id run-at]})

reset-failed-jobs! clj

(reset-failed-jobs! db)

reset-failed-jobs-by-queue! clj

(reset-failed-jobs-by-queue! db {:keys [queue]})

reset-queue-stats! clj

(reset-queue-stats! db {:keys [queue]})

reset-stats! clj

(reset-stats! db)

retry-failed-job! clj

(retry-failed-job! db {:keys [id]})

set-job-last-error! clj

(set-job-last-error! db {:keys [last-error id]})

upsert-job! clj

(upsert-job! db {:keys [queue job-name actor payload interval run-at]})