diff options
author | 2017-11-19 21:10:04 -0800 | |
---|---|---|
committer | 2017-11-19 22:01:46 -0800 | |
commit | 8ffb773f43c8dc54801ca1d111854e7e881c93c9 (patch) | |
tree | 38133a2fc612597a75fed1d13e5b4042f58a2b7e /scheduler/worker.go |
First commit
Diffstat (limited to 'scheduler/worker.go')
-rw-r--r-- | scheduler/worker.go | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/scheduler/worker.go b/scheduler/worker.go new file mode 100644 index 0000000..39382a3 --- /dev/null +++ b/scheduler/worker.go @@ -0,0 +1,35 @@ +// 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 ( + "github.com/miniflux/miniflux2/model" + "github.com/miniflux/miniflux2/reader/feed" + "log" + "time" +) + +// A Worker refresh a feed in the background. +type Worker struct { + id int + feedHandler *feed.Handler +} + +// Run wait for a job and refresh the given feed. +func (w *Worker) Run(c chan model.Job) { + log.Printf("[Worker] #%d started\n", w.id) + + for { + job := <-c + log.Printf("[Worker #%d] got userID=%d, feedID=%d\n", w.id, job.UserID, job.FeedID) + + err := w.feedHandler.RefreshFeed(job.UserID, job.FeedID) + if err != nil { + log.Println("Worker:", err) + } + + time.Sleep(time.Millisecond * 1000) + } +} |