Module eval_schedule 

Helpers for stable EVAL INTERVAL scheduled times.

Structs

DueScheduledTimes

Scheduled times selected for execution in one scheduler pass.

EvalSchedule

Schedule for an EVAL INTERVAL flow.

FlowScheduleConfig

Internal typed schedule configuration for EVAL INTERVAL flows.

Enums

FlowMissedTickPolicy

Policy for handling flow evaluation scheduled times that were missed.

Functions

ceil_to_boundary

Ceils time to the next anchor + k * interval boundary.

first_due_in_sequence 🔒

next_in_sequence 🔒

The smallest start + k * interval value that is strictly after cursor (start itself lies on the anchor + k * interval lattice, so every result is phase-consistent with the anchor). All arithmetic happens in i128: cursor - start cannot overflow and the result is either exactly on the lattice or an explicit error.

select_due_scheduled_times

Select due scheduled times <= wall_now_secs without materializing all missed ticks.