Struct Worker 

pub struct Worker<B: Broker> { /* private fields */ }

The worker loop that dequeues and executes tasks.

Implementations

impl<B: Broker> Worker<B>

pub fn new( broker: B, registry: TaskRegistry, context: TaskContext, config: WorkerConfig, ) -> Self

pub fn with_middleware(self, middleware: impl Middleware) -> Self

Add middleware to the worker pipeline.

pub fn with_middleware_boxed(self, middleware: Box<dyn Middleware>) -> Self

Add a boxed middleware to the worker pipeline.

pub fn cancel_token(&self) -> CancellationToken

Get the cancellation token for external shutdown triggering.

pub async fn run(&self)

Run the worker loop until shutdown.