Method latest_lsn

nodedb/src/event/cdc/buffer.rs:218–221

(&self)

    }

    pub fn latest_lsn(&self) -> Option<u64> {
        let events = self.events.read().unwrap_or_else(|p| p.into_inner());
        events.back().map(|e| e.lsn)
    }

    pub fn total_pushed(&self) -> u64 {
        self.total_pushed.load(std::sync::atomic::Ordering::Relaxed)