Struct ProcessWorkDriver 

pub struct ProcessWorkDriver { /* private fields */ }

Registry and run handle for process work owned outside LashCore.

The registry non-terminal rows are the durable work queue. Hosts drive that queue explicitly by calling claim_and_run_pending on each relevant event. Cross-process idempotency belongs to the registry claim; there is no core-owned polling loop.

Implementations

impl ProcessWorkDriver

pub fn new( registry: Arc<dyn ProcessRegistry>, run_handle: Arc<dyn ProcessRunHandle>, ) -> ProcessWorkDriver

pub fn inline( registry: Arc<dyn ProcessRegistry>, worker: DurableProcessWorker, ) -> ProcessWorkDriver

pub fn process_registry(&self) -> Arc<dyn ProcessRegistry>

pub async fn claim_and_run_pending( &self, reason: &str, ) -> Result<(), PluginError>

Trait Implementations

impl Clone for ProcessWorkDriver

fn clone(&self) -> ProcessWorkDriver

Returns a duplicate of the value.

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

Performs copy-assignment from source.