|
|
|
@ -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 { |
|
|
|
|