Method query_changes

nodedb/src/control/change_stream/stream.rs:250–265

Query recent changes for a collection since a given timestamp. Returns change events matching the collection filter that occurred at or after `since_ms` (epoch milliseconds). Limited to the ring buffer capacity (most recent N events).

(
        &self,
        collection: Option<&str>,
        since_ms: u64,
        limit: usize,
    )

    /// at or after `since_ms` (epoch milliseconds). Limited to the ring
    /// buffer capacity (most recent N events).
    pub fn query_changes(
        &self,
        collection: Option<&str>,
        since_ms: u64,
        limit: usize,
    ) -> Vec<ChangeEvent> {
        let buf = match self.recent_changes.read() {
            Ok(b) => b,
            Err(p) => p.into_inner(),
        };
        buf.iter()
            .filter(|e| e.timestamp_ms >= since_ms && collection.is_none_or(|c| e.collection == c))
            .take(limit)
            .cloned()
            .collect()
    }

    /// Manually decrement the active subscription counter.
    ///