risingwave_storage::hummock::utils

Function wait_for_epoch

source 
pub(crate) async fn wait_for_epoch(
    notifier: &Sender<PinnedVersion>,
    wait_epoch: u64,
    table_id: TableId,
) -> StorageResult<()>
Expand description

Wait for the committed_epoch of table_id to reach wait_epoch.

When the table_id does not exist in the latest version, we assume that the table is not created yet, and will wait until the table is created.