diff options
Diffstat (limited to 'service/scheduler/scheduler.go')
| -rw-r--r-- | service/scheduler/scheduler.go | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/service/scheduler/scheduler.go b/service/scheduler/scheduler.go index a5e41d5..7a8eb1c 100644 --- a/service/scheduler/scheduler.go +++ b/service/scheduler/scheduler.go @@ -16,8 +16,20 @@ import ( // Serve starts the internal scheduler. func Serve(store *storage.Storage, pool *worker.Pool) { logger.Info(`Starting scheduler...`) - go feedScheduler(store, pool, config.Opts.PollingFrequency(), config.Opts.BatchSize()) - go cleanupScheduler(store, config.Opts.CleanupFrequency(), config.Opts.ArchiveReadDays(), config.Opts.RemoveSessionsDays()) + + go feedScheduler( + store, + pool, + config.Opts.PollingFrequency(), + config.Opts.BatchSize(), + ) + + go cleanupScheduler( + store, + config.Opts.CleanupFrequencyHours(), + config.Opts.CleanupArchiveReadDays(), + config.Opts.CleanupRemoveSessionsDays(), + ) } func feedScheduler(store *storage.Storage, pool *worker.Pool, frequency, batchSize int) { |