diff options
Diffstat (limited to 'internal/workers/workers.go')
| -rw-r--r-- | internal/workers/workers.go | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/internal/workers/workers.go b/internal/workers/workers.go index 965cf1d2a..8f884d427 100644 --- a/internal/workers/workers.go +++ b/internal/workers/workers.go @@ -45,6 +45,19 @@ type Workers struct { EnqueueClientAPI func(context.Context, ...messages.FromClientAPI) EnqueueFediAPI func(context.Context, ...messages.FromFediAPI) + // Blocking processing functions for clientAPI / federator. + // These are pointers to Processor{}.Process___() msg functions. + // This prevents dependency cycling as Processor depends on Workers. + // + // Rather than queueing messages for asynchronous processing, these + // functions will process immediately and in a blocking manner, and + // will not use up a worker slot. + // + // As such, you should only call them in special cases where something + // synchronous needs to happen before you can do something else. + ProcessFromClientAPI func(context.Context, messages.FromClientAPI) error + ProcessFromFediAPI func(context.Context, messages.FromFediAPI) error + // Media manager worker pools. Media runners.WorkerPool |