Method start_lsn

src/sql-server-util/src/cdc.rs:124–131

Set the [`Lsn`] that we should start streaming changes from. If the provided [`Lsn`] is not available, the stream will return an error when first polled.

(mut self, capture_instance: &str, lsn: Lsn)

    /// If the provided [`Lsn`] is not available, the stream will return an error
    /// when first polled.
    pub fn start_lsn(mut self, capture_instance: &str, lsn: Lsn) -> Self {
        let start_lsn = self
            .capture_instances
            .get_mut(capture_instance)
            .expect("capture instance does not exist");
        *start_lsn = Some(lsn);
        self
    }

    /// The cadence at which we'll poll the upstream SQL Server database for changes.
    ///