Struct WorkerRegistry

pub struct WorkerRegistry { /* private fields */ }

Registry for job workers

This registry maps job method names to their corresponding worker implementations. It’s used by the job processor to find the appropriate worker for each job.

Implementations

impl WorkerRegistry

pub fn new() -> Self

Create a new worker registry

pub fn register<W>(&mut self, worker: W)

where W: Worker + 'static,

Register a worker for a specific method

pub fn get_worker(&self, method: &str) -> Option<&dyn Worker>

Get a worker for the given method name

pub fn get_methods(&self) -> Vec<&str>

Get all registered method names

pub fn has_worker(&self, method: &str) -> bool

Check if a method is registered

pub fn len(&self) -> usize

Get the number of registered workers

pub fn is_empty(&self) -> bool

Check if the registry is empty

Trait Implementations

impl Default for WorkerRegistry

fn default() -> WorkerRegistry

Returns the “default value” for a type.