diff options
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 { |