Method drain_due

nodedb/src/event/trigger/retry.rs:90–114

Drain all entries whose retry time has arrived. Returns `(ready_for_retry, exceeded_max_retries)`.

(&mut self)

    /// Drain all entries whose retry time has arrived.
    /// Returns `(ready_for_retry, exceeded_max_retries)`.
    pub fn drain_due(&mut self) -> (Vec<RetryEntry>, Vec<RetryEntry>) {
        let now = Instant::now();
        let mut ready = Vec::new();
        let mut exhausted = Vec::new();

        // Drain from front (oldest first).
        while self.queue.front().is_some_and(|e| e.next_retry_at <= now) {
            let Some(entry) = self.queue.pop_front() else {
                break;
            };
            if entry.attempts >= self.max_retries {
                warn!(
                    trigger = %entry.trigger_name,
                    collection = %entry.collection,
                    attempts = entry.attempts,
                    "trigger exhausted max retries → DLQ"
                );
                exhausted.push(entry);
            } else {
                ready.push(entry);
            }
        }

        (ready, exhausted)
    }

    /// Number of entries pending retry.
    pub fn len(&self) -> usize {