Skip to main content

Module eval_schedule

Module eval_schedule 

Source
Expand description

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 🔒
select_due_scheduled_times
Select due scheduled times <= wall_now_secs without materializing all missed ticks.