taskmaster.operation — taskmaster 0.0.4-SNAPSHOT-1

*job-table-name* clj

Default name of the table to store job records

create-jobs-table! clj

(create-jobs-table! conn)

Creates the jobs table, also will setup necessary triggers on the jobs table

create-jobs-table*! clj

(create-jobs-table*! db)

(create-jobs-table*! db params)

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

create-jobs-table*!-sqlvec clj

(create-jobs-table*!-sqlvec)

(create-jobs-table*!-sqlvec params)

(create-jobs-table*!-sqlvec params options)

(sqlvec)

delete-all! clj

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

Launches a nuclear missle and nukes all of the jobs for given queue

delete-all*! clj

(delete-all*! db)

(delete-all*! db params)

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

delete-all*!-sqlvec clj

(delete-all*!-sqlvec)

(delete-all*!-sqlvec params)

(delete-all*!-sqlvec params options)

(sqlvec)

delete-job! clj

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

Launches a missle 🚀

delete-jobs*! clj

(delete-jobs*! db)

(delete-jobs*! db params)

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

delete-jobs*!-sqlvec clj

(delete-jobs*!-sqlvec)

(delete-jobs*!-sqlvec params)

(delete-jobs*!-sqlvec params options)

(sqlvec)

drop-jobs-table! clj

(drop-jobs-table! conn)

Drop the jobs table, along with its triggers

drop-jobs-table*! clj

(drop-jobs-table*! db)

(drop-jobs-table*! db params)

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

drop-jobs-table*!-sqlvec clj

(drop-jobs-table*!-sqlvec)

(drop-jobs-table*!-sqlvec params)

(drop-jobs-table*!-sqlvec params options)

(sqlvec)

find-failed-jobs clj

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

Find all failed jobs in given queue

find-jobs* clj

(find-jobs* db)

(find-jobs* db params)

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

find-jobs*-sqlvec clj

(find-jobs*-sqlvec)

(find-jobs*-sqlvec params)

(find-jobs*-sqlvec params options)

(sqlvec)

get-by-ids* clj

(get-by-ids* db)

(get-by-ids* db params)

(get-by-ids* db params options & command-options)

get-by-ids*-sqlvec clj

(get-by-ids*-sqlvec)

(get-by-ids*-sqlvec params)

(get-by-ids*-sqlvec params options)

(sqlvec)

listen* clj

(listen* db)

(listen* db params)

(listen* db params options & command-options)

listen*-sqlvec clj

(listen*-sqlvec)

(listen*-sqlvec params)

(listen*-sqlvec params options)

(sqlvec)

listen-and-notify clj

(listen-and-notify {:keys [datasource] :as _conn}
                   {:keys [queue-name handler interval-ms]})

LOW LEVEL BITS ALERT! The core of the job listener for a given queue:

• unpacks the raw connection from the connection pool
• pings the trigger
• pulls all pending jobs and passes them to the handler

Notifications are polled at a 500ms interval, or can be adjusted via interval-ms argument handler receives multiple notification job payloads

lock! clj

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

Lock a table row using advisory locks and SKIP locked, returns the whole job row (with the ID, payload and so on

lock*! clj

(lock*! db)

(lock*! db params)

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

lock*!-sqlvec clj

(lock*!-sqlvec)

(lock*!-sqlvec params)

(lock*!-sqlvec params options)

(sqlvec)

ping* clj

(ping* db)

(ping* db params)

(ping* db params options & command-options)

ping*-sqlvec clj

(ping*-sqlvec)

(ping*-sqlvec params)

(ping*-sqlvec params options)

(sqlvec)

put! clj

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

Schedule a job for execution

put*! clj

(put*! db)

(put*! db params)

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

put*!-sqlvec clj

(put*!-sqlvec)

(put*!-sqlvec params)

(put*!-sqlvec params options)

(sqlvec)

put-many*! clj

(put-many*! db)

(put-many*! db params)

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

put-many*!-sqlvec clj

(put-many*!-sqlvec)

(put-many*!-sqlvec params)

(put-many*!-sqlvec params options)

(sqlvec)

queue-size clj

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

How many jobs we have, for the whole queue - only pending ones.

queue-size* clj

(queue-size* db)

(queue-size* db params)

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

queue-size*-sqlvec clj

(queue-size*-sqlvec)

(queue-size*-sqlvec params)

(queue-size*-sqlvec params options)

(sqlvec)

queue-stats clj

(queue-stats conn)

Return number of jobs per queue in the jobs table

queue-stats* clj

(queue-stats* db)

(queue-stats* db params)

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

queue-stats*-sqlvec clj

(queue-stats*-sqlvec)

(queue-stats*-sqlvec params)

(queue-stats*-sqlvec params options)

(sqlvec)

requeue! clj

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

Requeues the job, without changing the payload and deletes old ones

setup-triggers*! clj

(setup-triggers*! db)

(setup-triggers*! db params)

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

setup-triggers*!-sqlvec clj

(setup-triggers*!-sqlvec)

(setup-triggers*!-sqlvec params)

(setup-triggers*!-sqlvec params options)

(sqlvec)

unlock! clj

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

Release the lock for given job ID

unlock*! clj

(unlock*! db)

(unlock*! db params)

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

unlock*!-sqlvec clj

(unlock*!-sqlvec)

(unlock*!-sqlvec params)

(unlock*!-sqlvec params options)

(sqlvec)

unlock-dead-consumers! clj

(unlock-dead-consumers! conn)

Free all locks, which are held by consumers which no longer exist (due to a crash etc)

unlock-dead-consumers*! clj

(unlock-dead-consumers*! db)

(unlock-dead-consumers*! db params)

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

unlock-dead-consumers*!-sqlvec clj

(unlock-dead-consumers*!-sqlvec)

(unlock-dead-consumers*!-sqlvec params)

(unlock-dead-consumers*!-sqlvec params options)

(sqlvec)

wrap-handler clj

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

LOW LEVEL BITS ALERT! Wrap the handler function in such a way, that it deletes the jobs once they're processed successfully. All of the processing happens in a transaction