Module epoch

Modules

• task_local
  Task-local storage for the epoch pair.

Structs

• Epoch
• EpochPair

Constants

• EPOCH_AVAILABLE_BITS
• EPOCH_INC_MIN_STEP_FOR_TEST 🔒
• EPOCH_MASK 🔒
• EPOCH_PHYSICAL_SHIFT_BITS 🔒
• EPOCH_SPILL_TIME_MASK
• INVALID_EPOCH
  INVALID_EPOCH defines the invalid epoch value.
• MAX_EPOCH
• MAX_SPILL_TIMES

Statics

• UNIX_RISINGWAVE_DATE_EPOCH
  UNIX_RISINGWAVE_DATE_EPOCH represents the risingwave date of the UNIX epoch: 2021-04-01T00:00:00Z.
• UNIX_RISINGWAVE_DATE_SEC 🔒

Traits

• EpochExt
  There are numerous operations in our system’s unit tests that involve incrementing or decrementing the epoch. These extensions for u64 type are specifically used within the unit tests.

Functions

• is_compatibility_max_epoch
• is_max_epoch
• test_epoch
  As most unit tests initialize a new epoch from a random value (e.g. 1, 2, 233 etc.), but the correct epoch in the system is a u64 with the last EPOCH_AVAILABLE_BITS bits set to 0. This method is to turn a a random epoch into a well shifted value.