Struct WorkerRegistry

pub struct WorkerRegistry { /* private fields */ }

Worker registry for managing job handlers

Implementations

impl WorkerRegistry

pub fn new() -> Self

Create a new worker registry

pub async fn register<T: Job + JobTypeProvider + 'static>( &self, handler: impl JobProcessor<T> + Send + Sync + 'static, )

Register a job handler for a specific job type

pub async fn get_handler(&self, job_type: &str) -> Option<JobHandler>

Get a handler for a job type

pub async fn list_job_types(&self) -> Vec<String>

List all registered job types

Trait Implementations

impl Default for WorkerRegistry

fn default() -> Self

Returns the “default value” for a type.