diff options
author | 2018-11-11 15:32:48 -0800 | |
---|---|---|
committer | 2018-11-11 15:32:48 -0800 | |
commit | 487852f07eb191ef56967b7b7d7f01537a55eabd (patch) | |
tree | 0c5194c4371392128917a0860ac7a6b00f7784a2 /scheduler/scheduler.go | |
parent | ca45765c46de3b00c3b22936c885b57c37186e3d (diff) |
Replace daemon and scheduler package with service package
Diffstat (limited to 'scheduler/scheduler.go')
-rw-r--r-- | scheduler/scheduler.go | 44 |
1 files changed, 0 insertions, 44 deletions
diff --git a/scheduler/scheduler.go b/scheduler/scheduler.go deleted file mode 100644 index f0a8134..0000000 --- a/scheduler/scheduler.go +++ /dev/null @@ -1,44 +0,0 @@ -// Copyright 2017 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/scheduler" - -import ( - "time" - - "miniflux.app/logger" - "miniflux.app/storage" -) - -// NewFeedScheduler starts a new scheduler that push jobs to a pool of workers. -func NewFeedScheduler(store *storage.Storage, workerPool *WorkerPool, frequency, batchSize int) { - go func() { - c := time.Tick(time.Duration(frequency) * time.Minute) - for range c { - jobs, err := store.NewBatch(batchSize) - if err != nil { - logger.Error("[FeedScheduler] %v", err) - } else { - logger.Debug("[FeedScheduler] Pushing %d jobs", len(jobs)) - workerPool.Push(jobs) - } - } - }() -} - -// NewCleanupScheduler starts a new scheduler that clean old sessions and archive read items. -func NewCleanupScheduler(store *storage.Storage, frequency int) { - go func() { - c := time.Tick(time.Duration(frequency) * time.Hour) - for range c { - nbSessions := store.CleanOldSessions() - nbUserSessions := store.CleanOldUserSessions() - logger.Info("[CleanupScheduler] Cleaned %d sessions and %d user sessions", nbSessions, nbUserSessions) - - if err := store.ArchiveEntries(); err != nil { - logger.Error("[CleanupScheduler] %v", err) - } - } - }() -} |