Method cdc

src/sql-server-util/src/lib.rs:334–345

Return a [`CdcStream`] that can be used to track changes for the specified `capture_instances`. [`CdcStream`]: crate::cdc::CdcStream

(&mut self, capture_instances: I, metrics: M)

    ///
    /// [`CdcStream`]: crate::cdc::CdcStream
    pub fn cdc<I, M>(&mut self, capture_instances: I, metrics: M) -> crate::cdc::CdcStream<'_, M>
    where
        I: IntoIterator,
        I::Item: Into<Arc<str>>,
        M: SqlServerCdcMetrics,
    {
        let instances = capture_instances
            .into_iter()
            .map(|i| (i.into(), None))
            .collect();
        crate::cdc::CdcStream::new(self, instances, metrics)
    }
}

/// A stream of [`tiberius::Row`]s.