Struct SopDriverRegistry 

pub struct SopDriverRegistry { /* private fields */ }

Spawn a background task that drives a resumed SOP action to its next blocking or terminal state. Gate-clearing surfaces without an ambient agent turn (HTTP decide, WS approvals, manual dashboard runs) land here: ExecuteStep runs through a fresh agent loop under the step’s resolved agent, DeterministicStep routes through the engine’s headless deterministic driver, and every other action is already parked or terminal.

Returns the driver’s task handle. A caller whose config and engine belong to a bounded lifetime (the daemon’s SOP maintenance tick, which is rebuilt on reload) must keep it and drain or cancel the driver when that lifetime ends; otherwise the driver keeps running against superseded configuration. Callers with no such boundary drop it to detach. A daemon generation’s set of headless driver handles, plus whether that generation has finalized it.

Registration and finalization race by construction: an approval can resolve on a connection task whose listener has already stopped accepting, so a driver can be produced after the drain has taken the set. A bare vector accepts that handle into a collection nobody drains again, and the driver runs on under superseded config and permissions — the exact escape the generation boundary exists to prevent. Closing the set makes the late registration fail instead.

Implementations

impl SopDriverRegistry

pub fn len(&self) -> usize

Handles this generation currently tracks.

pub fn is_empty(&self) -> bool

Whether this generation currently tracks no drivers.

pub fn is_closed(&self) -> bool

Whether the owning generation has finalized this set.

pub fn close_and_take(&mut self) -> Vec<JoinHandle<()>>

Take every tracked handle and close the set. Taking and closing are one operation deliberately: a caller that took the handles without closing would leave later registrations landing in a set it no longer drains.

pub fn close_and_take_owned(&mut self) -> Vec<RegisteredSopDriver>

Self::close_and_take, keeping each driver’s run. The teardown that may have to abort a driver uses this, so it can settle the run the aborted driver will never advance.

Trait Implementations

impl Debug for SopDriverRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for SopDriverRegistry

fn default() -> SopDriverRegistry

Returns the “default value” for a type.