Struct EffectDriver 

pub struct EffectDriver { /* private fields */ }

Drives steps: performs their effects, journals them, emits their events.

Implementations

impl EffectDriver

pub fn new(journal: EffectJournal) -> Self

A driver over journal, with no handlers yet — add them with Self::with_handler; an effect nobody claims is a clear error.

pub fn with_catalog(self, catalog: Arc<NodeCatalog>) -> Self

Provide the step library that dynamic fan-out draws from.

pub fn with_handler(self, handler: Arc<dyn EffectHandler>) -> Self

Add a handler. The first whose handles() claims an effect performs it.

pub fn with_event_bus(self, bus: Arc<EventBus>) -> Self

Emit the agent events (turns, effects, handoffs) to this bus.

pub fn run( &self, step: &dyn Step, run_id: &str, node_id: &str, input: &Value, ) -> Result<NodeOutcome>

Run a step to completion.

Bounded by somatize_core::step::StepMeta::max_turns: a step that has not finished by then is looping, and stopping with a clear error beats burning tokens until something else gives out.

pub fn resume_with( &self, run_id: &str, node_id: &str, turn: usize, reason: &SuspendReason, answer: Value, ) -> Result<()>

Deliver the answer a suspended run was waiting for.

Recorded at the exact site the step suspended, so the next run under the same id replays to that point and finds it. There is no separate checkpoint file: the journal is the checkpoint.

node_id, turn and reason come from the NodeOutcome::Paused that stopped the run.

Trait Implementations

impl Clone for EffectDriver

fn clone(&self) -> EffectDriver

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.