From 228862fefaa645026caa483ffe9993bf8c00b22e Mon Sep 17 00:00:00 2001 From: Frédéric Guillot Date: Sat, 1 Jun 2019 18:18:09 -0700 Subject: Refactor config package - Parse configuration only once during startup time - Store configuration values in a global variable --- service/scheduler/scheduler.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'service/scheduler') diff --git a/service/scheduler/scheduler.go b/service/scheduler/scheduler.go index 184bb49..1d51356 100644 --- a/service/scheduler/scheduler.go +++ b/service/scheduler/scheduler.go @@ -14,10 +14,10 @@ import ( ) // Serve starts the internal scheduler. -func Serve(cfg *config.Config, store *storage.Storage, pool *worker.Pool) { +func Serve(store *storage.Storage, pool *worker.Pool) { logger.Info(`Starting scheduler...`) - go feedScheduler(store, pool, cfg.PollingFrequency(), cfg.BatchSize()) - go cleanupScheduler(store, cfg.CleanupFrequency(), cfg.ArchiveReadDays()) + go feedScheduler(store, pool, config.Opts.PollingFrequency(), config.Opts.BatchSize()) + go cleanupScheduler(store, config.Opts.CleanupFrequency(), config.Opts.ArchiveReadDays()) } func feedScheduler(store *storage.Storage, pool *worker.Pool, frequency, batchSize int) { -- cgit v1.2.3