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 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.

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.