aboutsummaryrefslogtreecommitdiff
path: root/internal/worker/worker.go
diff options
context:
space:
mode:
authorGravatar jvoisin <julien.voisin@dustri.org> 2024-02-28 23:44:12 +0100
committerGravatar Frédéric Guillot <f@miniflux.net> 2024-02-28 19:39:03 -0800
commit5e5cb056c5c424ec8ffee4c7d3c8745be4d1b489 (patch)
tree736557fc9c29ac4a66a52e54a1b0e5b5d12657b3 /internal/worker/worker.go
parent48fa64f8eca70ecc156e4081d3130d24da77775a (diff)
downloadv2-5e5cb056c5c424ec8ffee4c7d3c8745be4d1b489.tar.gz
v2-5e5cb056c5c424ec8ffee4c7d3c8745be4d1b489.tar.zst
v2-5e5cb056c5c424ec8ffee4c7d3c8745be4d1b489.zip
Make internal/worker/worker.go read-only
Since workers don't communicate anything back to the pool with the channel, there is no need to have it bidirectional.
Diffstat (limited to 'internal/worker/worker.go')
-rw-r--r--internal/worker/worker.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/worker/worker.go b/internal/worker/worker.go
index d8195f97..0ef0b01f 100644
--- a/internal/worker/worker.go
+++ b/internal/worker/worker.go
@@ -21,7 +21,7 @@ type Worker struct {
}
// 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),
)