Module service

Structs§

ExecutorServiceImpl: AtlasClient is cheap to clone — each Execute RPC clones it so per-plan dispatch runs without serialising on a single mutex.

execute_call 🔒: Dispatch one RTDL do node and stream node_state events.
execute_node 🔒
executor_health_report 🔒
is_operator_node 🔒: Return whether a node kind is an RTDL operator rather than a leaf call.
leaf_terminal_state 🔒: Map a completed leaf call to its RTDL state. Cancellation wins over the provider result: a command terminated by cancel_plan normally returns success=false, but that is an expected CANCELED outcome, not a FAILED tool.
node_event_context 🔒: Build the wire context copied into every node_state event.
send_operator_terminal 🔒: Stream the terminal event for a non-leaf RTDL operator node, and record the state so get_plan_status reflects it.
send_stop_on_enter 🔒: Emit the terminal event for an on_enter stop point on any RTDL node.
validate_call 🔒
validate_plan 🔒: Validate Plan arena shape before spawning execution work.
visit_for_cycles 🔒: DFS cycle check on the plan arena following only sequence/parallel child edges.