From dff4d455e07d639b82a0bed814f41d0656e9b6d0 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Sat, 21 Sep 2024 14:03:45 +0300 Subject: cleanup --- internal/server/cron/cron.go | 45 -------------------------------------------- 1 file changed, 45 deletions(-) delete mode 100644 internal/server/cron/cron.go (limited to 'internal/server/cron') 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) -} -- cgit v1.2.3