Method enqueue

nodedb/src/event/trigger/dlq.rs:142–188

Enqueue a failed trigger event.

(&mut self, params: DlqEnqueueParams)

    /// Enqueue a failed trigger event.
    pub fn enqueue(&mut self, params: DlqEnqueueParams) -> crate::Result<u64> {
        let entry_id = self.next_entry_id;
        self.next_entry_id += 1;

        let now = SystemTime::now()
            .duration_since(UNIX_EPOCH)
            .unwrap_or_default()
            .as_millis() as u64;

        let entry = TriggerDlqEntry {
            entry_id,
            tenant_id: params.tenant_id,
            source_collection: params.source_collection,
            row_id: params.row_id,
            operation: params.operation,
            trigger_name: params.trigger_name,
            error: params.error,
            retry_count: params.retry_count,
            source_lsn: params.source_lsn,
            source_sequence: params.source_sequence,
            created_at: now,
            resolved: false,
        };

        // Evict oldest if at capacity.
        while self.entries.len() >= self.max_entries {
            if let Some(evicted) = self.entries.pop_front() {
                self.delete_from_redb(evicted.entry_id);
                warn!(
                    entry_id = evicted.entry_id,
                    trigger = %evicted.trigger_name,
                    "trigger DLQ evicted oldest entry (at capacity)"
                );
            }
        }

        // Persist to redb.
        self.write_to_redb(&entry)?;

        debug!(
            entry_id,
            trigger = %entry.trigger_name,
            "trigger event sent to DLQ"
        );
        self.entries.push_back(entry);
        Ok(entry_id)
    }

    /// List all unresolved DLQ entries.
    pub fn list_unresolved(&self) -> Vec<&TriggerDlqEntry> {