diff options
| author | Paul Buetow <paul@buetow.org> | 2024-08-11 14:57:54 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2024-08-11 14:57:54 +0300 |
| commit | 8eba8522dc6fb9a558fa88d4f6abc45eeb1e58c9 (patch) | |
| tree | a430c35e841c5604dc8da24cca25a5830e03f373 | |
| parent | 4fbe8284ce4d6d6f9da563785bab1278f69c5f9d (diff) | |
add cron.go
| -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 +} |
