From fb9a1a61297a8f1882d27067f69d84d46c8286e7 Mon Sep 17 00:00:00 2001 From: Ty Cobb Date: Sun, 15 Sep 2019 13:47:39 -0500 Subject: Rename cleanup config variables The config parser logs a warning when the user uses a deprecated variable. It also ignores the value from a deprecated variable if it has already been set using the corresponding non-deprecated variable (and logs another warning). - CLEANUP_FREQUENCY_HOURS instead of CLEANUP_FREQUENCY - CLEANUP_ARCHIVE_READ_DAYS instead of ARCHIVE_READ_DAYS --- service/scheduler/scheduler.go | 16 ++++++++++++++-- 1 file changed, 14 insertions(+), 2 deletions(-) (limited to 'service') 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) { -- cgit v1.2.3