Struct SupervisorBuilder 

pub struct SupervisorBuilder<'a> { /* private fields */ }

Builds a Supervisor with configurable runtime loops.

Worker, scheduler, and reaper loops are enabled by default. Call Self::with_registry or Self::with_catalog before Self::build when worker or reaper loops remain enabled.

Implementations

impl<'a> SupervisorBuilder<'a>

pub fn with_registry(self, registry: JobRegistry) -> Self

Registers the handlers used by worker execution and reaper terminal hooks.

A registry is required when worker or reaper loops are enabled. Scheduler-only supervisors can be built without one.

pub fn with_catalog(self, catalog: impl Borrow<JobCatalog>) -> Self

Registers handlers from a JobCatalog.

This does not sync database job definitions. Call JobCatalog::sync_definitions before starting the supervisor or creating schedules. Pass &catalog when the caller will continue using the catalog for schedule, enqueue, or workflow helpers after building the supervisor.

Registry Source

Calling this and Self::with_registry on the same builder is rejected by Self::build. Choose one registration source per builder.

pub fn disable_worker(self) -> Self

Disables worker job claiming and execution for this supervisor.

pub fn disable_scheduler(self) -> Self

Disables cron schedule materialization for this supervisor.

pub fn disable_reaper(self) -> Self

Disables expired-lease reaping for this supervisor.

pub fn build(self) -> Result<Supervisor, RuntimeError>

Starts the enabled runtime loops and returns the owning supervisor.

Returns an error when worker or reaper loops are enabled without a job registry.