diff options
Diffstat (limited to 'service/scheduler')
-rw-r--r-- | service/scheduler/doc.go | 10 | ||||
-rw-r--r-- | service/scheduler/scheduler.go | 46 |
2 files changed, 56 insertions, 0 deletions
diff --git a/service/scheduler/doc.go b/service/scheduler/doc.go new file mode 100644 index 0000000..94615ad --- /dev/null +++ b/service/scheduler/doc.go @@ -0,0 +1,10 @@ +// Copyright 2018 Frédéric Guillot. All rights reserved. +// Use of this source code is governed by the Apache 2.0 +// license that can be found in the LICENSE file. + +/* + +Package scheduler implements the scheduler service. + +*/ +package scheduler // import "miniflux.app/service/scheduler" diff --git a/service/scheduler/scheduler.go b/service/scheduler/scheduler.go new file mode 100644 index 0000000..31c63e7 --- /dev/null +++ b/service/scheduler/scheduler.go @@ -0,0 +1,46 @@ +// Copyright 2018 Frédéric Guillot. All rights reserved. +// Use of this source code is governed by the Apache 2.0 +// license that can be found in the LICENSE file. + +package scheduler // import "miniflux.app/service/scheduler" + +import ( + "time" + + "miniflux.app/config" + "miniflux.app/logger" + "miniflux.app/storage" + "miniflux.app/worker" +) + +// Serve starts the internal scheduler. +func Serve(cfg *config.Config, store *storage.Storage, pool *worker.Pool) { + go feedScheduler(store, pool, cfg.PollingFrequency(), cfg.BatchSize()) + go cleanupScheduler(store, cfg.CleanupFrequency()) +} + +func feedScheduler(store *storage.Storage, pool *worker.Pool, frequency, batchSize int) { + c := time.Tick(time.Duration(frequency) * time.Minute) + for range c { + jobs, err := store.NewBatch(batchSize) + if err != nil { + logger.Error("[Scheduler:Feed] %v", err) + } else { + logger.Debug("[Scheduler:Feed] Pushing %d jobs", len(jobs)) + pool.Push(jobs) + } + } +} + +func cleanupScheduler(store *storage.Storage, frequency int) { + c := time.Tick(time.Duration(frequency) * time.Hour) + for range c { + nbSessions := store.CleanOldSessions() + nbUserSessions := store.CleanOldUserSessions() + logger.Info("[Scheduler:Cleanup] Cleaned %d sessions and %d user sessions", nbSessions, nbUserSessions) + + if err := store.ArchiveEntries(); err != nil { + logger.Error("[Scheduler:Cleanup] %v", err) + } + } +} |