pub fn open_stream(
config: StreamConfig,
snapshot_lsn: u64,
in_transaction: bool,
clock: &dyn Clock,
) -> Result<StreamLease, OpenStreamError>Expand description
Issue a lease. The caller is responsible for binding snapshot_lsn
to the same MVCC view the underlying executor will read from; in the
shim slice this is runtime.cdc_current_lsn() captured before
execute_query.