Struct SpecDriver 

pub struct SpecDriver { /* private fields */ }

Durable driver compiled from a product spec; see the module docs.

Implementations

impl SpecDriver

pub fn new(spec: &Spec, registry: &NodeRegistry) -> Result<Self, HostError>

Compile spec; rejects action nodes without an Action manifest and funds actions.

Trait Implementations

impl<Context: Send + Sync> WorkflowDriver<Context> for SpecDriver

fn name(&self) -> &'static str

Stable driver name.

fn spec_ids(&self) -> Vec<&str>

Specs this driver owns.

fn validate_specs(&self) -> Result<(), String>

Reject a spec set the driver cannot serve; the reason is reported as SupervisorError::Driver.

fn evaluate<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _: &'life1 Context, item: &'life2 WorkItem, ) -> Pin<Box<dyn Future<Output = Result<WorkflowTransitionCommand, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Evaluate deterministic workflow state and return one durable command. External effects must be represented as prepared ActionIntents and dispatched later by a registered provider.