Struct WorkerPool 

pub struct WorkerPool<B: QueueBackend + ?Sized> {
    pub backend: Arc<B>,
    /* private fields */
}

Fields

backend: Arc<B>

Implementations

impl<B: QueueBackend + 'static> WorkerPool<B>

pub fn new(backend: B, config: WorkerConfig) -> Self

impl<B: QueueBackend + ?Sized + 'static> WorkerPool<B>

pub fn new_with_arc(backend: Arc<B>, config: WorkerConfig) -> Self

Create new worker pool from existing Arc backend (supports dyn dispatch)

pub fn register_job_type<J: Job + DeserializeOwned + 'static>(&self, name: &str)

Register a job type handler

pub fn register_job_factory<F>(&self, name: &str, factory: F)

where F: Fn(Value) -> Box<dyn Job> + Send + Sync + 'static,

Register a custom factory (useful for jobs with dependency injection)

pub async fn start(&self)