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

Create a new worker with the given broker, task registry, shared context, and config.

Prefer KojinBuilder (from the kojin facade crate) for ergonomic construction.

pub fn with_result_backend(self, backend: Arc<dyn ResultBackend>) -> Self

Set the result backend.

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.