diff options
| -rw-r--r-- | internal/server/cron/cron.go | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/internal/server/cron/cron.go b/internal/server/cron/cron.go new file mode 100644 index 0000000..6e1c5fa --- /dev/null +++ b/internal/server/cron/cron.go @@ -0,0 +1,28 @@ +package cron + +import ( + "context" + "log" + "time" + + config "codeberg.org/snonux/gos/internal/config/server" +) + +func Start(ctx context.Context, conf config.ServerConfig) error { + go func() { + helloTicker := time.NewTicker(10 * time.Second) + mergeTicker := time.NewTicker(time.Duration(conf.CRONMergeIntervalS) * time.Second) + + for { + select { + case <-ctx.Done(): + return + case <-helloTicker.C: + log.Println("Hello ticker ticked") + case <-mergeTicker.C: + log.Println("CRON merge ticker ticked") + } + } + }() + return nil +} |
