Skip to main content

Module pool

Module pool 

Source
Expand description

Worker pool — manages a fleet of concurrent worker Tokio tasks.

WorkerPool spawns N worker tasks, each with its own queue affinity. Workers share the same StateBackend (via Arc) and executor registry.

Queue isolation is achieved by assigning specific queue_types to each worker. For example, model workers only claim from the ["model"] queue, while general workers handle ["general", "tool"].

Structs§

WorkerGroupConfig
Configuration for a worker pool group (workers sharing the same queues).
WorkerPool
A pool of concurrent worker tasks.

Functions§

default_pool
Convenience: build a default pool with standard queue groups.