class ScheduleState

Defined in:

crdo/schedule_state.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(test : Bool, immediate : Bool, filter : Set(String), crontab : String, clock : Clock = SystemClock.new, output : IO = STDOUT) #

[View source]

Instance Method Detail

def [](name : String) #

[View source]
def []?(name : String) #

[View source]
def add_tasks(tasks) #

[View source]
def apply_pass_result(pass_time : Time, reasons : Array(TaskRunDecision)) #

[View source]
def automatic_reports? : Bool #

[View source]
def autosave : Time::Span #

[View source]
def clock : Clock #

[View source]
def filter : Set(String) #

[View source]
def has_deferred_replacement?(name : String) #

[View source]
def immediate : Bool #

[View source]
def load_initial_state #

[View source]
def mail_failures : Array(MailFailure) #

[View source]
def next_task_wait(state : TaskState) #

[View source]
def previous_now : Time? #

[View source]
def print_report #

[View source]
def print_running_report #

[View source]
def promote_deferred_replacement(name, snapshot) #

[View source]
def reasons : Array(TaskRunDecision) #

[View source]
def record_mail_failure(task_name : String, log_dir : String, message : String) #

[View source]
def reload_config #

[View source]
def remove_task(task_state : TaskState) #

[View source]
def reporter : ScheduleReporter #

[View source]
def restore_state #

[View source]
def running #

[View source]
def save_state #

[View source]
def select(*args, **options) #

[View source]
def select(*args, **options, &) #

[View source]
def states : Array(TaskState) #

[View source]
def task_wait_state(state : TaskState, now : Time = @clock.now) #

[View source]
def test : Bool #

[View source]
def test=(test : Bool) #

[View source]