risingwave_common::util::epoch

Module task_local

Expand description

Task-local storage for the epoch pair.

Statics§

TASK_LOCAL_EPOCH_PAIR 🔒

Functions§

curr_epoch: Retrieve the current epoch from the task local storage.
epoch: Retrieve the epoch pair from the task local storage.
prev_epoch: Retrieve the previous epoch from the task local storage.
scope: Provides the given epoch pair in the task local storage for the scope of the given future.