Module supervisor

Expand description

Database-agnostic scheduler for claimed long-running workflow instances.

Structs§

DriverRegistry: Drivers keyed by the specs they own.
EvaluationOutcome: Completion-policy accounting for one evaluation.
MemoryWorkQueue: In-memory WorkQueue for consumer unit tests: hands out queued items in order and records every committed command. No leases, no durability.
SupervisorSettings: Pass configuration.
SupervisorStats: Result of one pass.
Wakeup: A durable fact that became due for a claimed instance: an expired timer or a pending trigger delivery. The driver reads it; the queue marks it consumed in the same transaction that commits the driver’s command.
WorkItem: One claimed instance with everything a driver needs to evaluate it.
WorkflowTransitionCommand: The only result a workflow driver may return. The queue commits the state, event, intents and scheduling disposition atomically before any provider is allowed to dispatch an external effect.

SupervisorError: Failure at the supervisor boundary. Driver evaluation reasons stay String because they are product-authored text recorded verbatim in the failure event; everything the kernel itself decides is typed here.
WorkDisposition: What the queue does with the instance after committing a command.

run_due_pass: One supervisor pass: claim due work, evaluate concurrently under renewed leases, commit every command. A failing context factory requeues every claimed item with the failure.