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.