taskmaster.operation — taskmaster 0.0.3-SNAPSHOT-1

*job-table-name* clj

create-jobs-table! clj

(create-jobs-table! conn)

create-jobs-table*! clj

(create-jobs-table*! db)

(create-jobs-table*! db params)

(create-jobs-table*! db params options & command-options)

delete-all! clj

(delete-all! conn {:keys [queue-name]})

delete-all*! clj

(delete-all*! db)

(delete-all*! db params)

(delete-all*! db params options & command-options)

delete-job! clj

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

delete-job*! clj

(delete-job*! db)

(delete-job*! db params)

(delete-job*! db params options & command-options)

drop-jobs-table! clj

(drop-jobs-table! conn)

drop-jobs-table*! clj

(drop-jobs-table*! db)

(drop-jobs-table*! db params)

(drop-jobs-table*! db params options & command-options)

find-pending-jobs clj

(find-pending-jobs conn {:keys [queue-name]})

find-pending-jobs* clj

(find-pending-jobs* db)

(find-pending-jobs* db params)

(find-pending-jobs* db params options & command-options)

listen* clj

(listen* db)

(listen* db params)

(listen* db params options & command-options)

listen-and-notify clj

(listen-and-notify {:keys [datasource] :as conn}
                   {:keys [queue-name handler on-error interval-ms] :as opts})

lock! clj

(lock! conn {:keys [queue-name]})

lock*! clj

(lock*! db)

(lock*! db params)

(lock*! db params options & command-options)

ping* clj

(ping* db)

(ping* db params)

(ping* db params options & command-options)

put! clj

(put! conn {:keys [queue-name payload]})

put*! clj

(put*! db)

(put*! db params)

(put*! db params options & command-options)

queue-size clj

(queue-size conn {:keys [queue-name]})

queue-size* clj

(queue-size* db)

(queue-size* db params)

(queue-size* db params options & command-options)

setup-triggers*! clj

(setup-triggers*! db)

(setup-triggers*! db params)

(setup-triggers*! db params options & command-options)

unlock! clj

(unlock! conn {:keys [id]})

unlock*! clj

(unlock*! db)

(unlock*! db params)

(unlock*! db params options & command-options)

unlock-dead-consumers! clj

(unlock-dead-consumers! conn)

unlock-dead-consumers*! clj

(unlock-dead-consumers*! db)

(unlock-dead-consumers*! db params)

(unlock-dead-consumers*! db params options & command-options)

wrap-handler clj

(wrap-handler conn {:keys [queue-name handler]})

Wrap the handler function in such a way, that it deletes the jobs once they're processed successfully