Struct QueueHandle 

pub struct QueueHandle { /* private fields */ }

Implementations

impl QueueHandle

pub fn host_id(&self) -> &str

Per-boot identifier. Surfaced for tests + diagnostics.

pub const fn storage(&self) -> &Storage

Read-only access to the storage for IPC commands.

pub fn rate_limit(&self) -> &RateLimiter

Cluster-wide rate limiter — same instance every worker’s JobCtx::rate_limit points at. Surfaced so out-of-band callers (e.g. cron tasks spawned outside the worker loop) can acquire against the same budget as in-flight jobs.

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

Signal a cancel for an in-flight job by id.

If the job is running on this pod, cancels its in-process token immediately and returns true. If the job isn’t on this pod (or isn’t running at all) returns false; cross-pod cancels go through JobQueue::delete on an in_progress row, which sets a DB flag the owning pod’s heartbeat tick observes within HEARTBEAT_INTERVAL.

pub async fn enqueue(&self, req: EnqueueRequest) -> Result<EnqueueOutcome>

Enqueue from a different task after start. Same semantics as QueueRuntime::enqueue.

pub async fn shutdown_graceful(self, timeout: Duration)

Signal shutdown, wait up to timeout for in-flight jobs to drain, then delete process registry rows for this host.

Trait Implementations

impl Debug for QueueHandle

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

Formats the value using the given formatter.