Malli schemas for the worker-pool component.
Malli schemas for the worker-pool component.
Operational metrics snapshot for a worker pool.
Operational metrics snapshot for a worker pool.
Map of task-identifier strings to handler functions. Each fn receives a context map {:job job :job-system sys :worker-id wid}.
Map of task-identifier strings to handler functions.
Each fn receives a context map {:job job :job-system sys :worker-id wid}.A worker pool handle returned by create-pool.
A worker pool handle returned by create-pool.
Tuning parameters for a worker pool.
:concurrency - number of worker threads (default 10). :poll-interval-ms - sleep between polls when no jobs found (default 2000). :queue-size - max jobs held in the local buffer (default 50). :queue-ttl-ms - entries older than this are discarded on take (default 60000). :graceful-shutdown-timeout-ms - max time to wait for in-flight jobs on stop! (default 30000). :task-identifiers - restrict claims to these task types (nil = all). :forbidden-flags - skip jobs carrying any of these flags (nil = none).
Tuning parameters for a worker pool. :concurrency - number of worker threads (default 10). :poll-interval-ms - sleep between polls when no jobs found (default 2000). :queue-size - max jobs held in the local buffer (default 50). :queue-ttl-ms - entries older than this are discarded on take (default 60000). :graceful-shutdown-timeout-ms - max time to wait for in-flight jobs on stop! (default 30000). :task-identifiers - restrict claims to these task types (nil = all). :forbidden-flags - skip jobs carrying any of these flags (nil = none).
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 |