Expand description
Recurring-job poller.
RecurringJobPoller is the runtime counterpart to the
RecurringJob storage contract. Every
poll_interval it asks the storage backend for due templates,
materializes each one into a normal Job via [Storage::enqueue],
then advances next_run_at and upserts the row back. Backends
implement fetch_due_recurring_jobs with locking (Postgres: FOR UPDATE SKIP LOCKED, Redis: per-row SET NX) so two servers running
the poller in parallel cannot double-fire the same tick.
Structs§
- Recurring
JobPoller - Background poller that materializes due [
RecurringJob] templates.
Constants§
- DEFAULT_
RECURRING_ BATCH_ SIZE - Maximum number of recurring templates claimed per tick. A large backlog (e.g. after a long downtime) drains across multiple ticks rather than all at once.