Method read_partition_from_lsn

nodedb/src/event/cdc/buffer.rs:142–155

Read events from a specific partition, starting after `from_lsn`. Partition = vShard ID. Scans the buffer and filters by partition.

(
        &self,
        partition_id: u32,
        from_lsn: u64,
        limit: usize,
    )

    /// Read events from a specific partition, starting after `from_lsn`.
    /// Partition = vShard ID. Scans the buffer and filters by partition.
    pub fn read_partition_from_lsn(
        &self,
        partition_id: u32,
        from_lsn: u64,
        limit: usize,
    ) -> Vec<Arc<CdcEvent>> {
        let events = self.events.read().unwrap_or_else(|p| p.into_inner());
        events
            .iter()
            .filter(|e| e.partition == partition_id && e.lsn > from_lsn)
            .take(limit)
            .cloned()
            .collect()
    }

    /// Compact the buffer: deduplicate by key field, keeping only the latest
    /// event per key value. DELETE events are retained as tombstones until