Struct SopDriverSink 

pub struct SopDriverSink { /* private fields */ }

Owned spawner for headless run drivers at an ingress boundary.

Channel-triggered runs previously ended at process_headless_results, which only logs that an ExecuteStep is ready: nothing executed the run (the channel half of the headless-driver gap). Attaching this sink to SopIngress routes every Started action from ANY caller into the same supervised handle set the daemon’s SOP maintenance drains, so reload and cancellation ownership cannot diverge by trigger source — the alternative, each caller spawning and dropping its own JoinHandle, is exactly what this exists to prevent.

Implementations

impl SopDriverSink

pub fn new( config: Config, engine: Arc<Mutex<SopEngine>>, audit: Option<Arc<SopAuditLogger>>, handles: Arc<Mutex<SopDriverRegistry>>, ) -> SopDriverSink

pub fn handles(&self) -> Arc<Mutex<SopDriverRegistry>>

The handle set this sink registers drivers into, for the owner that drains them across reload and shutdown.

pub fn drive(&self, action: &SopRunAction)

Drive one dispatch action if it needs a headless driver. Finished handles are pruned on the way in so a long-lived daemon does not accumulate them.

Trait Implementations

impl Clone for SopDriverSink

fn clone(&self) -> SopDriverSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.