From 2f859ec0514deeb572834ed167ce707929480779 Mon Sep 17 00:00:00 2001 From: kim Date: Wed, 24 Apr 2024 13:09:06 +0100 Subject: [PATCH] code comments, ensure dereferencer worker pool gets started --- internal/workers/workers.go | 12 ++++++++---- testrig/util.go | 3 +++ 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/internal/workers/workers.go b/internal/workers/workers.go index b964cf123..54dfcabe9 100644 --- a/internal/workers/workers.go +++ b/internal/workers/workers.go @@ -37,16 +37,20 @@ type Workers struct { // indexed queue of Delivery{} objects. Delivery delivery.WorkerPool - // Client ... + // Client provides a worker pool that handles + // incoming processing jobs from the client API. Client MsgWorkerPool[*messages.FromClientAPI] - // Federator ... + // Federator provides a worker pool that handles + // incoming processing jobs from the fedi API. Federator MsgWorkerPool[*messages.FromFediAPI] - // Dereferencer worker pools. + // Dereference provides a worker pool + // for asynchronous dereferencer jobs. Dereference FnWorkerPool - // Media manager worker pools. + // Media provides a worker pool for + // asynchronous media processing jobs. Media FnWorkerPool // prevent pass-by-value. diff --git a/testrig/util.go b/testrig/util.go index e384adac2..2e52f7008 100644 --- a/testrig/util.go +++ b/testrig/util.go @@ -49,6 +49,7 @@ func StartNoopWorkers(state *state.State) { _ = state.Workers.Scheduler.Start() _ = state.Workers.Client.Start(1) _ = state.Workers.Federator.Start(1) + _ = state.Workers.Dereference.Start(1) _ = state.Workers.Media.Start(1) } @@ -65,6 +66,7 @@ func StartWorkers(state *state.State, processor *workers.Processor) { _ = state.Workers.Scheduler.Start() _ = state.Workers.Client.Start(1) _ = state.Workers.Federator.Start(1) + _ = state.Workers.Dereference.Start(1) _ = state.Workers.Media.Start(1) } @@ -72,6 +74,7 @@ func StopWorkers(state *state.State) { _ = state.Workers.Scheduler.Stop() _ = state.Workers.Client.Stop() _ = state.Workers.Federator.Stop() + _ = state.Workers.Dereference.Stop() _ = state.Workers.Media.Stop() }