cljobq.job
dbjob->friendly-job
(dbjob->friendly-job dbjob)
delete-and-fail-job!
(delete-and-fail-job! db {:keys [id]})
delete-failed-job-by-id!
(delete-failed-job-by-id! db {:keys [id]})
delete-job!
(delete-job! db {:keys [id]})
delete-job-by-name!
(delete-job-by-name! db {:keys [queue job-name]})
delete-queue-jobs!
(delete-queue-jobs! db {:keys [queue]})
get-failed-job-by-id
(get-failed-job-by-id db {:keys [id]})
get-failed-jobs
(get-failed-jobs db)
get-failed-jobs-by-queue
(get-failed-jobs-by-queue db {:keys [queue]})
get-job-by-id
(get-job-by-id db {:keys [id]})
get-job-by-name
(get-job-by-name db {:keys [queue job-name]})
get-job-stats
(get-job-stats db)
get-jobs-by-queue
(get-jobs-by-queue db {:keys [queue]})
get-jobs-with-error
(get-jobs-with-error db)
get-queue-stats
(get-queue-stats db)
get-recurring-jobs
(get-recurring-jobs db)
get-stats
(get-stats db)(get-stats db queue)
identifiers
(identifiers x)
inc-queue-fail!
(inc-queue-fail! db {:keys [queue retries]})
inc-queue-success!
(inc-queue-success! db {:keys [queue retries]})
insert-job!
(insert-job! db {:keys [queue job-name actor payload interval run-at]})
list-failed-jobs
(list-failed-jobs db)(list-failed-jobs db queue)
list-jobs
(list-jobs db)(list-jobs db queue)
list-queue-names
(list-queue-names db)
list-recurring-jobs
(list-recurring-jobs db)(list-recurring-jobs db queue)
pick-job-by-queue!
(pick-job-by-queue! db {:keys [queue base-timeout backoff-factor max-timeout]})
reenqueue-and-fail-job!
(reenqueue-and-fail-job! db {:keys [id run-at]})
reenqueue-job!
(reenqueue-job! db {:keys [id run-at]})
reset-failed-jobs!
(reset-failed-jobs! db)
reset-failed-jobs-by-queue!
(reset-failed-jobs-by-queue! db {:keys [queue]})
reset-queue-stats!
(reset-queue-stats! db {:keys [queue]})
reset-stats!
(reset-stats! db)
retry-failed-job!
(retry-failed-job! db {:keys [id]})
set-job-last-error!
(set-job-last-error! db {:keys [last-error id]})
upsert-job!
(upsert-job! db {:keys [queue job-name actor payload interval run-at]})