Struct KojinBuilder 

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

Builder for configuring and running a Kojin worker.

Implementations

impl<B: Broker> KojinBuilder<B>

pub fn new(broker: B) -> Self

Create a new builder with the given broker.

pub fn register_task<T: Task>(self) -> Self

Register a task type.

pub fn data<T: Send + Sync + 'static>(self, value: T) -> Self

Add shared data accessible via ctx.data::<T>().

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

Add a middleware.

pub fn concurrency(self, n: usize) -> Self

Set concurrency (max parallel tasks).

pub fn queues(self, queues: Vec<String>) -> Self

Set queues to consume.

pub fn shutdown_timeout(self, timeout: Duration) -> Self

Set shutdown timeout.

pub fn result_backend(self, rb: impl ResultBackend) -> Self

Set the result backend for storing task results and workflow coordination.

A result backend is required for workflows (chain!, group!, chord) and for retrieving task return values. If you only need fire-and-forget execution, this can be omitted.

pub fn result_backend_shared(self, rb: Arc<dyn ResultBackend>) -> Self

Set a shared result backend (already wrapped in Arc).

Use this when the same backend must be shared between Canvas::apply() and the worker.

pub fn build(self) -> Worker<B>

Build the worker.