Method drain_for_persistence

nodedb/src/control/server/sync/dlq.rs:375–381

Drain all entries for WAL persistence. Returns all entries (resolved and unresolved) for serialization into WAL records. After draining, the in-memory DLQ is empty.

(&mut self)

    /// Returns all entries (resolved and unresolved) for serialization
    /// into WAL records. After draining, the in-memory DLQ is empty.
    pub fn drain_for_persistence(&mut self) -> Vec<DlqEntry> {
        let mut all = Vec::new();
        for queue in self.queues.values_mut() {
            all.extend(queue.drain(..));
        }
        all
    }

    /// Restore entries from WAL replay.
    pub fn restore_entry(&mut self, entry: DlqEntry) {