diff options
| author | Paul Buetow <paul@buetow.org> | 2024-09-21 14:03:45 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2024-09-21 14:03:45 +0300 |
| commit | dff4d455e07d639b82a0bed814f41d0656e9b6d0 (patch) | |
| tree | 56289a6fd80a00a9724992ab9cb8b3d7215ebedf /internal/server/cron | |
| parent | 780ade3dc066afb8a43be824373414f3d316ebd6 (diff) | |
cleanup
Diffstat (limited to 'internal/server/cron')
| -rw-r--r-- | internal/server/cron/cron.go | 45 |
1 files changed, 0 insertions, 45 deletions
diff --git a/internal/server/cron/cron.go b/internal/server/cron/cron.go deleted file mode 100644 index 3d6b9cf..0000000 --- a/internal/server/cron/cron.go +++ /dev/null @@ -1,45 +0,0 @@ -package cron - -import ( - "context" - "log" - "time" - - config "codeberg.org/snonux/gos/internal/config/server" - "codeberg.org/snonux/gos/internal/server/health" - "codeberg.org/snonux/gos/internal/server/repository" - "codeberg.org/snonux/gos/internal/server/scheduler" -) - -func Run(ctx context.Context, conf config.ServerConfig, status health.Status) { - helloTicker := time.NewTicker(time.Hour) - mergeTicker := time.NewTicker(time.Second * time.Duration(conf.MergeIntervalS)) - scheduleTicker := time.NewTicker(time.Second * time.Duration(conf.ScheduleIntervalS)) - - for { - select { - case <-ctx.Done(): - return - case <-helloTicker.C: - run(ctx, "cron->Hello", status, func(ctx context.Context) error { - log.Println("hello world") - return nil - }) - case <-mergeTicker.C: - run(ctx, "cron->repository.Merge", status, repository.Instance(conf).MergeRemotely) - case <-scheduleTicker.C: - run(ctx, "cron->scheduler.Run", status, func(ctx context.Context) error { - return scheduler.Run(ctx, conf) - }) - } - } -} - -func run(ctx context.Context, what string, status health.Status, cb func(ctx context.Context) error) { - log.Println("CRON ticker initiating", what) - if err := cb(ctx); err != nil { - status.Set(health.Critical, what, err) - return - } - status.Clear(what) -} |
