diff options
| author |  Ty Cobb <ty.cobb.m@gmail.com> | 2019-09-11 22:10:34 -0500 |
|---|---|---|
| committer |  Frédéric Guillot <fred@miniflux.net> | 2019-09-11 20:10:33 -0700 |
| commit | 3a60abbac07bd342f261fccb46bfd5b0039b3f74 (patch) | |
| tree | 2c1608b4918f83493f9a8e1a8482ce21d793690d /service | |
| parent | 8d8f78241d303381abf6879cc007ca9cbc2a12e2 (diff) | |
Make configurable the number of days to remove old sessions
Diffstat (limited to 'service')
| -rw-r--r-- | service/scheduler/scheduler.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/service/scheduler/scheduler.go b/service/scheduler/scheduler.go index 1d51356..a5e41d5 100644 --- a/service/scheduler/scheduler.go +++ b/service/scheduler/scheduler.go @@ -17,7 +17,7 @@ import ( 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()) + go cleanupScheduler(store, config.Opts.CleanupFrequency(), config.Opts.ArchiveReadDays(), config.Opts.RemoveSessionsDays()) } func feedScheduler(store *storage.Storage, pool *worker.Pool, frequency, batchSize int) { @@ -33,11 +33,11 @@ func feedScheduler(store *storage.Storage, pool *worker.Pool, frequency, batchSi } } -func cleanupScheduler(store *storage.Storage, frequency int, archiveDays int) { +func cleanupScheduler(store *storage.Storage, frequency int, archiveDays int, sessionsDays int) { c := time.Tick(time.Duration(frequency) * time.Hour) for range c { - nbSessions := store.CleanOldSessions() - nbUserSessions := store.CleanOldUserSessions() + nbSessions := store.CleanOldSessions(sessionsDays) + nbUserSessions := store.CleanOldUserSessions(sessionsDays) logger.Info("[Scheduler:Cleanup] Cleaned %d sessions and %d user sessions", nbSessions, nbUserSessions) if err := store.ArchiveEntries(archiveDays); err != nil { |