Method scan_with_surrogate

nodedb/src/engine/kv/scan.rs:59–85

Like [`scan`], but surfaces each row's surrogate alongside its key/value so a caller can filter by clone snapshot-isolation ceiling (drop rows bound after the AS-OF point).

(
        &self,
        cursor_idx: usize,
        count: usize,
        now_ms: u64,
        match_pattern: Option<&str>,
    )

    /// key/value so a caller can filter by clone snapshot-isolation
    /// ceiling (drop rows bound after the AS-OF point).
    pub fn scan_with_surrogate(
        &self,
        cursor_idx: usize,
        count: usize,
        now_ms: u64,
        match_pattern: Option<&str>,
    ) -> ScanBatchWithSurrogate<'_> {
        let mut results = Vec::with_capacity(count);
        let total_slots = self.capacity() + self.rehash_source_len();

        let mut idx = cursor_idx;
        while results.len() < count && idx < total_slots {
            let entry = self.slot_at(idx);

            if let Some(e) = entry
                && !e.is_expired(now_ms)
                && matches_pattern(&e.key, match_pattern)
            {
                let value = self.read_value(e);
                results.push((e.key.as_slice(), value, e.surrogate));
            }
            idx += 1;
        }

        let next_cursor = if idx >= total_slots { 0 } else { idx };
        (results, next_cursor)
    }

    /// Access a slot by unified index (primary first, then rehash source).
    fn slot_at(&self, idx: usize) -> Option<&KvEntry> {