Function mz_storage_controller::rtr::real_time_recency_ts

pub(crate) async fn real_time_recency_ts<T: Timestamp + Lattice + TotalOrder + Codec64 + From<EpochMillis>>(
    connection: GenericSourceConnection,
    id: GlobalId,
    config: StorageConfiguration,
    as_of: Antichain<T>,
    remap_subscribe: Subscribe<SourceData, (), T, Diff>,
) -> Result<T, StorageError<T>>

Determine the “real-time recency” timestamp for self.

Real-time recency is defined as the minimum value of T that id can be queried at to return all data visible in the upstream system the query was issued. In this case, “the upstream system” is the external system which self connects to.

Panics

• If self is a GenericSourceConnection::LoadGenerator. Load generator sources do not yet (or might never) support real-time recency. You can avoid this panic by choosing to not call this function on load generator sources.