class ScheduleRuntime

• ScheduleRuntime
• Reference
• Object

Defined in:

crdo/schedule_runtime.cr

Constructors

• .new(schedule : ScheduleState, clock : Clock, mailer : TaskMailer = TaskMailer.new)

Instance Method Summary

• #handle_event(event : SchedulerEvent) : Bool
• #handle_task_stopped(event : TaskStoppedEvent)
• #next_wake_timeout(reasons : Array(TaskRunDecision)) : Time::Span
• #run(events : Channel(SchedulerEvent) | Nil = nil)
• #run_due_tasks(events : Channel(SchedulerEvent))
• #shortest_timeout : Time::Span

Constructor Detail

Instance Method Detail