Modules§
Structs§
- Batching
Task - Execute
Once 🔒Outcome - Plan
Info - Task
Args - Arguments for creating batching task
- Task
Config - The task’s config, immutable once created
Enums§
Functions§
- determine_
query_ 🔒type - encode_
insert_ 🔒plan_ request - format_
insert_ 🔒target_ columns - initial_
schedule_ 🔒cursor - Initial scheduler cursor for
start_scheduled_loop: exactly one interval beforestart_secsso the first due scheduled time isstart_secsitself. - is_
merge_ 🔒mode_ last_ non_ null - scheduled_
time_ 🔒millis - Scheduled time in seconds converted to milliseconds for the
FLOW_SCHEDULED_TIME_MILLISextension. - sleep_
delta_ 🔒secs - Whole seconds to sleep until the next scheduled time
next, measured from the current wall clockwall_now_secs. - wall_
clock_ 🔒unix_ secs - Returns the current wall-clock Unix timestamp in seconds.