Method wait_for_ready

src/sql-server-util/src/cdc.rs:420–430

If CDC was recently enabled on an instance of SQL Server then it will report `NULL` for the minimum LSN of a capture instance and/or the maximum LSN of the entire database. This method runs a retry loop that waits for the upstream DB to report good values. It should be called before taking the initial [`CdcStream::snapshot`] to ensure the system is ready to proceed with CDC.

(&mut self)

    /// values. It should be called before taking the initial [`CdcStream::snapshot`]
    /// to ensure the system is ready to proceed with CDC.
    pub async fn wait_for_ready(&mut self) -> Result<(), SqlServerError> {
        // Ensure all of the capture instances are reporting an LSN.
        for instance in self.capture_instances.keys() {
            crate::inspect::get_min_lsn_retry(self.client, instance, self.max_lsn_wait).await?;
        }

        // Ensure the database is reporting a max LSN.
        crate::inspect::get_max_lsn_retry(self.client, self.max_lsn_wait).await?;

        Ok(())
    }
}

/// A change event from a [`CdcStream`].