From 18f55d156995371bfb06ca8cd91da5a922d2a937 Mon Sep 17 00:00:00 2001 From: Frédéric Guillot Date: Sat, 16 Dec 2017 18:48:17 -0800 Subject: Add scheduler to clean old sessions --- main.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'main.go') diff --git a/main.go b/main.go index 02f53c0..a252c61 100644 --- a/main.go +++ b/main.go @@ -47,13 +47,15 @@ func run(cfg *config.Config, store *storage.Storage) { pool := scheduler.NewWorkerPool(feedHandler, cfg.GetInt("WORKER_POOL_SIZE", config.DefaultWorkerPoolSize)) server := server.NewServer(cfg, store, pool, feedHandler) - scheduler.NewScheduler( + scheduler.NewFeedScheduler( store, pool, cfg.GetInt("POLLING_FREQUENCY", config.DefaultPollingFrequency), cfg.GetInt("BATCH_SIZE", config.DefaultBatchSize), ) + scheduler.NewSessionScheduler(store, config.DefaultSessionCleanupFrequency) + <-stop logger.Info("Shutting down the server...") ctx, _ := context.WithTimeout(context.Background(), 5*time.Second) -- cgit v1.2.3