Struct QueuedWorkDriver 

pub struct QueuedWorkDriver { /* private fields */ }

Implementations

impl QueuedWorkDriver

pub fn new(run_handle: Arc<dyn QueuedWorkRunHandle>) -> Self

pub fn with_shutdown_token( run_handle: Arc<dyn QueuedWorkRunHandle>, shutdown: CancellationToken, ) -> Self

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

pub fn wake_pending( &self, session_id: Option<&str>, reason: &str, ) -> JoinHandle<()>

Wake pending work without coupling dispatch success to the durable write that requested it.

The first claim happens on a spawned task so callers can return their durable acceptance receipt immediately. Operational failures are recorded as typed telemetry. Only typed transient failures retry, and both attempts and task lifetime are bounded; the underlying store scheduler remains the idempotency authority.

Trait Implementations

impl Clone for QueuedWorkDriver

fn clone(&self) -> QueuedWorkDriver

Returns a duplicate of the value.

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

Performs copy-assignment from source.