diff options
author | 2024-02-28 23:44:12 +0100 | |
---|---|---|
committer | 2024-02-28 19:39:03 -0800 | |
commit | 5e5cb056c5c424ec8ffee4c7d3c8745be4d1b489 (patch) | |
tree | 736557fc9c29ac4a66a52e54a1b0e5b5d12657b3 /internal/worker/worker.go | |
parent | 48fa64f8eca70ecc156e4081d3130d24da77775a (diff) | |
download | v2-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.go | 2 |
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), ) |