mirror of
https://github.com/miniflux/v2.git
synced 2025-09-15 18:57:04 +00:00
refactor: unexport symbols
This commit is contained in:
parent
a4d51b5586
commit
566670cc06
36 changed files with 369 additions and 376 deletions
|
@ -27,7 +27,7 @@ func NewPool(store *storage.Storage, nbWorkers int) *Pool {
|
|||
}
|
||||
|
||||
for i := range nbWorkers {
|
||||
worker := &Worker{id: i, store: store}
|
||||
worker := &worker{id: i, store: store}
|
||||
go worker.Run(workerPool.queue)
|
||||
}
|
||||
|
||||
|
|
|
@ -14,14 +14,14 @@ import (
|
|||
"miniflux.app/v2/internal/storage"
|
||||
)
|
||||
|
||||
// Worker refreshes a feed in the background.
|
||||
type Worker struct {
|
||||
// worker refreshes a feed in the background.
|
||||
type worker struct {
|
||||
id int
|
||||
store *storage.Storage
|
||||
}
|
||||
|
||||
// Run wait for a job and refresh the given feed.
|
||||
func (w *Worker) Run(c <-chan model.Job) {
|
||||
func (w *worker) Run(c <-chan model.Job) {
|
||||
slog.Debug("Worker started",
|
||||
slog.Int("worker_id", w.id),
|
||||
)
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue