proletarian.db — msolli/proletarian 1.0.21-alpha

archive-job! clj

(archive-job! conn
              {:proletarian.db/keys [job-table archived-job-table]}
              job-id
              status
              finished-at)

archive-job-sql clj

DEFAULT_ARCHIVED_JOB_TABLE clj

DEFAULT_JOB_TABLE clj

DEFAULT_QUEUE clj

delete-job! clj

(delete-job! conn {:proletarian.db/keys [job-table]} job-id)

delete-job-sql clj

enqueue! clj

(enqueue! conn
          {:proletarian.db/keys [job-table serializer]}
          {:proletarian.job/keys [job-id queue job-type payload attempts
                                  enqueued-at process-at]})

enqueue-sql clj

get-next-job clj

(get-next-job conn {:proletarian.db/keys [job-table serializer]} queue)

get-next-job-sql clj

retry-at! clj

(retry-at! conn {:proletarian.db/keys [job-table]} job-id retry-at)

retry-at-sql clj

with-connection clj

(with-connection ds f)

with-tx clj

(with-tx ds f)