Method pending_segments

nodedb/src/wal/archiver.rs:115–143

Scan the WAL directory for segments that need archiving. Returns segments with LSN > last_archived_lsn, sorted by LSN.

(&self)

    ///
    /// Returns segments with LSN > last_archived_lsn, sorted by LSN.
    pub fn pending_segments(&self) -> std::io::Result<Vec<WalSegment>> {
        let dir = &self.config.wal_dir;
        if !dir.exists() {
            return Ok(Vec::new());
        }

        let mut segments = Vec::new();
        for entry in std::fs::read_dir(dir)? {
            let entry = entry?;
            let path = entry.path();
            if !path.is_file() {
                continue;
            }

            // Parse segment filename: "wal-{first_lsn}-{last_lsn}.seg"
            if let Some(seg) = parse_segment_filename(&path)
                && seg.last_lsn > self.state.last_archived_lsn
            {
                segments.push(seg);
            }
        }

        segments.sort_by_key(|s| s.first_lsn);
        if segments.len() > self.config.batch_size {
            segments.truncate(self.config.batch_size);
        }

        Ok(segments)
    }

    /// Generate archive tasks for pending segments.
    ///