Scheduler as a first-class core module feature, following the same pattern used for the Asynq queue system

jacs commented

2026-06-13 19:21:35 -04:00

Contributor

Create a scheduler as a first-class core module feature, following the same pattern used for the Asynq queue system. The new core/scheduler/ subpackage contains QueueItem and ProcessedItem GORM models (tables queue_items and processed_items), a Store for database operations (enqueue, claim batch with SELECT FOR UPDATE SKIP LOCKED, result recording, stuck recovery), a Semaphore kill switch, and the polling Scheduler loop with configurable interval and rate limit. The core/scheduler.go wrapper exposes a Schedulermux struct (analogous to Queuemux) with SchedulerInit(), AddWork(), SetStore(), and RunScheduler() methods, plus global accessors ResolveSchedulerStore() and SchedulerSemaphoreSetGreen/Red/IsGreen() so controllers can enqueue work and control the semaphore without importing the subpackage directly.

jacs added 1 commit 2026-06-13 19:21:35 -04:00

Create a scheduler as a first-class core module feature, following the same pattern used for the Asynq queue system. The new core/scheduler/ subpackage contains QueueItem and ProcessedItem GORM models (tables queue_items and processed_items), a Store for database operations (enqueue, claim batch with SELECT FOR UPDATE SKIP LOCKED, result recording, stuck recovery), a Semaphore kill switch, and the polling Scheduler loop with configurable interval and rate limit. The core/scheduler.go wrapper exposes a Schedulermux struct (analogous to Queuemux) with SchedulerInit(), AddWork(), SetStore(), and RunScheduler() methods, plus global accessors ResolveSchedulerStore() and SchedulerSemaphoreSetGreen/Red/IsGreen() so controllers can enqueue work and control the semaphore without importing the subpackage directly. 3710fbe343

zeni merged commit 7ec601ca10 into develop

2026-06-21 22:09:23 -04:00

zeni referenced this pull request from a commit

2026-06-21 22:09:24 -04:00

Merge pull request 'Scheduler as a first-class core module feature, following the same pattern used for the Asynq queue system' (#32) from jacs/core:scheduler into develop

Rows
Columns

Scheduler as a first-class core module feature, following the same pattern used for the Asynq queue system #32