This repository has no description
docs: add todo about using jetstream only for the scheduler
author
Ewen Le Bihan
date
(Oct 31, 2024, 2:40 AM +0100)
commit
7d7fab82
7d7fab82025b966dbd91dffd57adebd550e08eb8
parent
ce3d0d28
ce3d0d289e40287ef9963e61bd0b8430d47668ad
+5
+5
scheduler.go
+5
scheduler.go
···
33
33
}
34
34
35
35
// StartScheduler starts the scheduler loop, which runs forever
36
+
// TODO instead of having a in-memory scheduler, use jetstream:
37
+
// 1. Get the message
38
+
// 2. job.ShouldRun? if yes, run it
39
+
// 3. otherwise, put it back at then end of the stream
40
+
// this means that we'll have to do a lot of json marshalling/unmarshalling though, since we'll have to decode the message to check if we need to run it... is there a better way?
36
41
func StartScheduler() {
37
42
for {
38
43
for _, job := range schedules.Items() {