diff options
Diffstat (limited to 'service/scheduler/scheduler.go')
| -rw-r--r-- | service/scheduler/scheduler.go | 6 |
1 files changed, 3 insertions, 3 deletions
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) { |