From f2b9094e301ac764930feaca93f1f0705f3e1a04 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Thu, 22 Aug 2024 10:31:43 +0300 Subject: initial scheduler --- internal/config/server/server.go | 22 +++++++++++++--------- 1 file changed, 13 insertions(+), 9 deletions(-) (limited to 'internal/config') diff --git a/internal/config/server/server.go b/internal/config/server/server.go index b43166c..88211a4 100644 --- a/internal/config/server/server.go +++ b/internal/config/server/server.go @@ -10,14 +10,15 @@ import ( ) type ServerConfig struct { - ListenAddr string `json:"ListenAddr,omitempty"` - Partner string `json:"Partner,omitempty"` - APIKey string `json:"APIKey,omitempty"` - DataDir string `json:"StateDir,omitempty"` - EmailTo string `json:"EmailTo,omitempty"` - EmailFrom string `json:"EmailFrom,omitempty"` - SMTPServer string `json:"SMTPServer,omitempty"` - CRONMergeIntervalS int `json:"CRONMergeInterval,omitempty"` + ListenAddr string `json:"ListenAddr,omitempty"` + Partner string `json:"Partner,omitempty"` + APIKey string `json:"APIKey,omitempty"` + DataDir string `json:"StateDir,omitempty"` + EmailTo string `json:"EmailTo,omitempty"` + EmailFrom string `json:"EmailFrom,omitempty"` + SMTPServer string `json:"SMTPServer,omitempty"` + MergeIntervalS int `json:"MergeInterval,omitempty"` + ScheduleIntervalS int `json:"ScheduleInterval,omitempty"` } func New(configFile string) (ServerConfig, error) { @@ -38,7 +39,10 @@ func New(configFile string) (ServerConfig, error) { return fmt.Sprintf("%s:25", hostname) }) - conf.CRONMergeIntervalS = config.EnvToInt("GOS_CRON_MERGE_INTERVAL", 3600) + const oneHour = 3600 + conf.MergeIntervalS = config.EnvToInt("GOS_MERGE_INTERVAL", oneHour) + conf.ScheduleIntervalS = config.EnvToInt("GOS_SCHEDULER_INTERVAL", oneHour*6) + return conf, nil } -- cgit v1.2.3