Struct WorkerPoolHandler 

pub struct WorkerPoolHandler { /* private fields */ }

A JobHandler that dispatches each job to a pooled long-lived subprocess. Construct with WorkerPoolHandler::spawn at boot and register on the HandlerRegistry.

Implementations

impl WorkerPoolHandler

pub async fn spawn(config: WorkerPoolConfig) -> Result<Self, String>

Build the pool and eagerly spawn config.size children (warm on first job). Fails if argv is empty or the first child can’t spawn.

Errors

Returns a message if argv is empty or a child fails to spawn.

Trait Implementations

impl Debug for WorkerPoolHandler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl JobHandler for WorkerPoolHandler

fn kind(&self) -> &'static str

Stable identifier matched against sync_queue.kind.

fn run<'life0, 'life1, 'async_trait>( &'life0 self, ctx: JobCtx<'life1>, payload: Value, ) -> Pin<Box<dyn Future<Output = JobOutcome> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Perform the unit of work. Returning JobOutcome::Done marks the row terminal-success; the other variants are described in the enum doc-comments.