Struct ClaimRequest 

pub struct ClaimRequest {
    pub worker_id: String,
    pub limit: usize,
    pub lease_ttl: Duration,
    pub allowed_run_ids: Option<Vec<RunId>>,
}

Parameters for claiming tasks from the queue.

Fields

worker_id: String

Worker identity (e.g. “worker-1”).

limit: usize

Maximum number of entries to claim.

lease_ttl: Duration

Lease TTL duration.

allowed_run_ids: Option<Vec<RunId>>

If set, only claim tasks belonging to these run IDs. None means no filtering (claim from any run).

Implementations

impl ClaimRequest

pub fn new( worker_id: impl Into<String>, limit: usize, lease_ttl: Duration, ) -> Self

pub fn single(worker_id: impl Into<String>) -> Self

Single-task claim with default 30s TTL.

pub fn with_allowed_run_ids(self, run_ids: Vec<RunId>) -> Self

Restrict claims to only the given run IDs.

Trait Implementations

impl Clone for ClaimRequest

fn clone(&self) -> ClaimRequest

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ClaimRequest

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

Formats the value using the given formatter.