Struct DriverRegistry 

pub struct DriverRegistry<Context: Send + Sync> { /* private fields */ }

Drivers keyed by the specs they own.

Implementations

impl<Context: Send + Sync> DriverRegistry<Context>

pub fn new() -> Self

Empty registry.

pub fn with_node_registry(self, nodes: NodeRegistry) -> Self

Enable lazy execution of published specs using this immutable registry snapshot.

pub fn prewarm_spec(&mut self, spec: &Spec) -> Result<(), String>

Precompile a shipped graph. Execution still requires its published revision.

pub async fn resolve_revision( &self, item: &WorkItem, revision: WorkflowRevision, ) -> Result<Arc<dyn WorkflowDriver<Context>>, String>

where Context: 'static,

Validate and compile the exact published graph, caching at most 256 revisions. Callers must load the revision through the owner-scoped durable queue first.

pub fn register( &mut self, driver: Arc<dyn WorkflowDriver<Context>>, ) -> Result<&mut Self, SupervisorError>

Register a driver. Duplicate spec ownership is a startup error because dispatch must never depend on registration order.

pub fn spec_ids(&self) -> Vec<String>

Every owned spec id, sorted.

pub fn for_spec( &self, spec_id: &str, ) -> Option<&Arc<dyn WorkflowDriver<Context>>>

Driver owning spec_id.

pub fn names(&self) -> Vec<&'static str>

Registered driver names.

pub fn is_empty(&self) -> bool

Whether no driver is registered or prewarmed; published graphs may still resolve lazily.

pub fn validate_all(&self) -> Result<(), SupervisorError>

Validate every driver’s spec set.

Trait Implementations

impl<Context: Send + Sync> Default for DriverRegistry<Context>

fn default() -> Self

Returns the “default value” for a type.