Skip to main content

claim_due_for_lane

Function claim_due_for_lane 

Source
pub async fn claim_due_for_lane<Store, Task, Kind, Lane, LaneFn>(
    store: &Store,
    lane_config: TaskLaneConfig<Kind, Lane>,
    processing_stale_secs: i64,
    task_lane: LaneFn,
) -> Result<Vec<(Task, TaskLease)>, Store::Error>
where Store: TaskClaimStore<Task, Kind, Lane>, Task: ClaimableTaskRecord<Kind> + Clone + Send + Sync, Kind: Copy + Eq + Debug + Display + Send + Sync + 'static, Lane: Copy + Eq + Debug + Send + Sync + 'static, LaneFn: Fn(Kind) -> Lane,
Expand description

Claims due tasks for a single lane using a product storage adapter.