develop #33
zeni
commented
Owner
No description provided.
zeni
added 2 commits 2026-06-21 22:41:07 -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
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
7ec601ca10
zeni
merged commit 6bc768ba77 into main
zeni
referenced this pull request from a commit
Merge pull request 'develop' (#33) from develop into main
Loading…
Add table
Add a link
Reference in a new issue
No description provided.
Delete branch "develop"
Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?