Method read_from_lsn

nodedb/src/event/cdc/buffer.rs:130–138

Read events from a given LSN forward (for consumer polling). Returns shared `Arc ` handles so repeated polls by webhook and Kafka producers share the underlying allocation.

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

    /// Returns shared `Arc<CdcEvent>` handles so repeated polls by webhook
    /// and Kafka producers share the underlying allocation.
    pub fn read_from_lsn(&self, 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.lsn > from_lsn)
            .take(limit)
            .cloned()
            .collect()
    }

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