Struct AcquireRequest 

pub struct AcquireRequest {
    pub plan_id: PlanId,
    pub caller_id: CallerId,
    pub max_count: usize,
    pub ids: Option<Vec<String>>,
    pub metadata_filter: Option<Map<String, Value>>,
    pub ttl: Option<Duration>,
}

Request bundle for crate::ports::Planner::acquire_cohort.

Public fields mirror the historical positional arguments so callers can construct it directly or via AcquireRequest::new.

Fields

plan_id: PlanId

caller_id: CallerId

max_count: usize

ids: Option<Vec<String>>

When set, only these deliverables are considered; each one that is not leased is reported in Cohort.blocked with a reason code.

metadata_filter: Option<Map<String, Value>>

When set, only deliverables whose metadata has every (key, value) pair (JSON equality) are considered. Non-matches are silently skipped.

ttl: Option<Duration>

Requested lease TTL for this call. None uses the planner default; the planner clamps the value to its configured maximum.

Implementations

impl AcquireRequest

pub fn new(plan_id: PlanId, caller_id: CallerId, max_count: usize) -> Self

pub fn with_ids(self, ids: Vec<String>) -> Self

Restrict the acquire to these deliverable ids.

pub fn with_metadata_filter(self, filter: Map<String, Value>) -> Self

Restrict the acquire to deliverables matching these metadata pairs.

pub fn with_ttl(self, ttl: Duration) -> Self

Request a lease TTL for this acquire. None (the default) uses the planner default TTL; the planner clamps the value to its configured maximum.

Trait Implementations

impl Clone for AcquireRequest

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AcquireRequest

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

Formats the value using the given formatter.