(add-job pool task-identifier payload)(add-job pool task-identifier payload opts)Add single job to queue.
Add single job to queue.
(add-jobs pool job-specs)Add multiple jobs to queue in transaction.
Add multiple jobs to queue in transaction.
(close-pool pool)Close connection pool and release resources.
Close connection pool and release resources.
(complete-jobs pool worker-id job-ids)Mark jobs as completed and remove from queue.
Mark jobs as completed and remove from queue.
(create-pool config)Create HikariCP connection pool from config map.
Create HikariCP connection pool from config map.
(execute! pool sql-map)(execute! pool sql-map opts)Execute SQL query with optional retry logic.
Execute SQL query with optional retry logic.
(execute-one! pool sql-map)(execute-one! pool sql-map opts)Execute SQL query returning single result.
Execute SQL query returning single result.
(fail-jobs pool worker-id job-failures)Mark jobs as failed with error details.
Mark jobs as failed with error details.
(force-unlock-jobs pool worker-ids)Clear locks on locked jobs. When worker-ids is provided, restricted to those workers.
Clear locks on locked jobs. When worker-ids is provided, restricted to those workers.
(force-unlock-queues pool queue-names)Clear locks on job queues. When queue-names is provided, restricted to those queues.
Clear locks on job queues. When queue-names is provided, restricted to those queues.
(gc-job-history pool)Remove expired job history records.
Remove expired job history records.
(gc-job-queues pool)Remove empty job queues.
Remove empty job queues.
(gc-task-identifiers pool)(gc-task-identifiers pool opts)Remove unused task identifiers.
Remove unused task identifiers.
(get-correlation-history pool correlation-id)Get history records for correlation-id.
Get history records for correlation-id.
(get-job-history pool job-id)Get history records for job-id.
Get history records for job-id.
(get-jobs pool worker-id)(get-jobs pool worker-id opts)Retrieve and claim available jobs for worker. Records a started history entry per job atomically. Returns jobs with :correlation-id embedded.
Retrieve and claim available jobs for worker. Records a started history entry per job atomically. Returns jobs with :correlation-id embedded.
(get-rate-limit pool key)Retrieve rate limit state by key. Returns nil if not found.
Retrieve rate limit state by key. Returns nil if not found.
(health-check pool)Performs a simple health check by executing a basic query. Returns true if the database is accessible, false otherwise.
Performs a simple health check by executing a basic query. Returns true if the database is accessible, false otherwise.
(load-crontab-state pool identifier)Return last_execution and known_since for identifier, or nil if not found.
Return last_execution and known_since for identifier, or nil if not found.
(permanently-fail-jobs pool job-ids reason)Set jobs to exhausted status with reason. Unlocks any queues affected.
Set jobs to exhausted status with reason. Unlocks any queues affected.
(query-job-history pool criteria)Return job history records matching criteria map.
Return job history records matching criteria map.
(record-job-completion pool
job-id
worker-id
correlation-id
execution-time-ms
_results)Record successful job completion.
Record successful job completion.
(record-job-failure pool
job-id
worker-id
correlation-id
execution-time-ms
error)Record job failure with error details.
Record job failure with error details.
(record-job-start pool job worker-id correlation-id)(record-job-start pool job worker-id correlation-id retention)Record job execution start.
Record job execution start.
(record-partial-success pool
job-id
worker-id
correlation-id
execution-time-ms
partial-results)Record partial job success with step details.
Record partial job success with step details.
(refill-rate-limits pool)Reset tokens to capacity for all rate limits whose window has expired. Returns count of limits refilled.
Reset tokens to capacity for all rate limits whose window has expired. Returns count of limits refilled.
(register-rate-limit pool key capacity interval)Register or update a rate limit. Creates a new limit with full capacity, or updates capacity and interval on an existing one (preserving current tokens).
Register or update a rate limit. Creates a new limit with full capacity, or updates capacity and interval on an existing one (preserving current tokens).
(replay-failed-jobs pool criteria)Replay failed jobs matching criteria.
Replay failed jobs matching criteria.
(reschedule-jobs pool job-ids opts)Update run-at for jobs.
Update run-at for jobs.
(reset-locked-jobs pool)(reset-locked-jobs pool opts)Reset locked jobs exceeding timeout.
Reset locked jobs exceeding timeout.
(update-last-execution! pool identifier)Set last_execution = now() for identifier in known_crontabs.
Set last_execution = now() for identifier in known_crontabs.
(upsert-crontab! pool identifier)Insert known_crontabs entry if identifier is not already present.
Insert known_crontabs entry if identifier is not already present.
(with-transaction pool f)Execute f within transaction, passing connection.
Execute f within transaction, passing connection.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |