Struct SupervisorBuilder 

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

Builds a Supervisor with configurable runtime loops.

Worker execution, durable intent promotion, scheduler, and reaper loops are enabled by default. Disabling the worker also disables intent promotion; SupervisorBuilder::disable_intent_promoter can disable only promotion. Every enabled supervisor polls independently, including when no intents are pending. Deployments may tune IntentPromoterConfig or disable redundant promoters, but must retain promoter coverage for every registered type that can receive durable intents. Call SupervisorBuilder::with_registry or SupervisorBuilder::with_catalog before SupervisorBuilder::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, execution, and durable intent promotion for this supervisor.

pub fn disable_intent_promoter(self) -> Self

Disables durable enqueue-intent promotion while leaving ordinary worker claiming and execution enabled.

Use this only when another compatible promoter covers every job type that can receive intents, or when the application never records intents. Disabling all applicable promoters leaves accepted intents pending indefinitely.

pub fn with_intent_promoter_config(self, config: IntentPromoterConfig) -> Self

Overrides the intent promoter’s polling and batch controls.

This does not enable a promoter disabled by Self::disable_worker or Self::disable_intent_promoter.

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 with_job_lifecycle_observer( self, observer: impl JobLifecycleObserver + 'static, ) -> Self

Registers a best-effort observer for committed job lifecycle events.

Observer callbacks run outside Runledger storage transactions. A callback timeout or panic is logged and does not change durable job state.

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.