Struct ChainJobRunnerHandle 

pub struct ChainJobRunnerHandle { /* private fields */ }

Implementations

impl ChainJobRunnerHandle

pub fn kick(&self)

Nudge the runner: a job row was inserted/reset to queued.

pub fn request_cancel(&self, job_id: &str) -> bool

Mark cancel-requested; false when the job is unknown to the registry.

pub fn unregister_cancel(&self, job_id: &str)

pub async fn lock_job(&self, job_id: &str) -> OwnedMutexGuard<()>

pub fn remove_job_lock(&self, job_id: &str)

pub async fn request_gc(&self) -> Result<GcOutcome>

pub fn cleanup_deleted(&self, job_id: &str)

pub fn publish_settled_state( &self, job_id: &str, state: ChainJobState, error: Option<String>, )

pub fn subscribe( &self, db: &MetadataDb, job_id: &str, ) -> Result<Receiver<ChainJobEvent>>

SSE attach: MUST be called BEFORE snapshot synthesis (buffered duplicates arriving after Snapshot are the correct side of the race; clients apply idempotently). Lagged receivers re-attach -> fresh Snapshot.