class JoobQ::DelayedJobScheduler

Defined in:

joobq/delayed_job_scheduler.cr

Constant Summary

Log = ::Log.for("DELAYED_JOB_SCHEDULER")

Constructors

Instance Method Summary

Constructor Detail

def self.new(store : Store = RedisStore.instance) #

[View source]

Instance Method Detail

def delay(job : Job, delay_time : Time::Span) #

[View source]
def start #

Start the scheduler to process due delayed jobs


[View source]
def stop #

Stop the scheduler


[View source]