summaryrefslogtreecommitdiff
path: root/internal/server/cron
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2024-09-21 14:03:45 +0300
committerPaul Buetow <paul@buetow.org>2024-09-21 14:03:45 +0300
commitdff4d455e07d639b82a0bed814f41d0656e9b6d0 (patch)
tree56289a6fd80a00a9724992ab9cb8b3d7215ebedf /internal/server/cron
parent780ade3dc066afb8a43be824373414f3d316ebd6 (diff)
cleanup
Diffstat (limited to 'internal/server/cron')
-rw-r--r--internal/server/cron/cron.go45
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)
-}