risingwave_common::util::epoch

Module task_local

source
Expand description

Task-local storage for the epoch pair.

Statics§

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.