class Rufus::Scheduler::RepeatJob
Constants
- FIRSTS
Attributes
first_at[R]
last_at[R]
paused_at[R]
times[RW]
Public Class Methods
new(scheduler, duration, opts, block)
click to toggle source
Calls superclass method
Rufus::Scheduler::Job::new
# File lib/rufus/scheduler/jobs_repeat.rb, line 10 def initialize(scheduler, duration, opts, block) super @paused_at = nil @times = opts[:times] fail ArgumentError.new( "cannot accept :times => #{@times.inspect}, not nil or an int" ) unless @times == nil || @times.is_a?(Integer) self.first_at = opts[:first] || opts[:first_time] || opts[:first_at] || opts[:first_in] || nil self.last_at = opts[:last] || opts[:last_at] || opts[:last_in] end
Public Instance Methods
determine_id()
click to toggle source
# File lib/rufus/scheduler/jobs_repeat.rb, line 103 def determine_id [ self.class.name.split(':').last.downcase[0..-4], @scheduled_at.to_f, (self.object_id < 0 ? 'm' : '') + self.object_id.to_s ].map(&:to_s).join('_') end
first_at=(first)
click to toggle source
# File lib/rufus/scheduler/jobs_repeat.rb, line 32 def first_at=(first) return (@first_at = nil) if first == nil n0 = EoTime.now n1 = n0 + 0.003 first = n0 if FIRSTS.include?(first) fdur = Rufus::Scheduler.parse_duration(first, no_error: true) @first_at = (fdur && (EoTime.now + fdur)) || EoTime.make(first) @first_at = n1 if @first_at >= n0 && @first_at < n1 fail ArgumentError.new( "cannot set first[_at|_in] in the past: " + "#{first.inspect} -> #{@first_at.inspect}" ) if @first_at < n0 @first_at end
last_at=(last)
click to toggle source
# File lib/rufus/scheduler/jobs_repeat.rb, line 53 def last_at=(last) @last_at = if last ldur = Rufus::Scheduler.parse_duration(last, no_error: true) (ldur && (EoTime.now + ldur)) || EoTime.make(last) else nil end fail ArgumentError.new( "cannot set last[_at|_in] in the past: " + "#{last.inspect} -> #{@last_at.inspect}" ) if last && @last_at < EoTime.now @last_at end
next_times(count)
click to toggle source
Starting from now, returns the {count} next occurences (EtOrbi::EoTime instances) for this job.
Warning, for IntervalJob, the @mean_work_time is used since “interval” works from the end of a job to its next trigger (not from one trigger to the next, as for “cron” and “every”).
# File lib/rufus/scheduler/jobs_repeat.rb, line 140 def next_times(count) (count - 1).times.inject([ next_time ]) { |a| a << next_time_from(a.last) a } end
occurrences(time0, time1)
click to toggle source
# File lib/rufus/scheduler/jobs_repeat.rb, line 112 def occurrences(time0, time1) a = [] nt = @next_time ts = @times loop do break if nt > time1 break if ts && ts <= 0 a << nt if nt >= time0 nt = next_time_from(nt) ts = ts - 1 if ts end a end
pause()
click to toggle source
# File lib/rufus/scheduler/jobs_repeat.rb, line 86 def pause @paused_at = EoTime.now end
paused?()
click to toggle source
# File lib/rufus/scheduler/jobs_repeat.rb, line 98 def paused? !! @paused_at end
resume(opts={})
click to toggle source
# File lib/rufus/scheduler/jobs_repeat.rb, line 91 def resume(opts={}) @resume_discard_past = opts[:discard_past] #p [ :@resume_discard_past, @resume_discard_past ] @paused_at = nil end
trigger(time)
click to toggle source
Calls superclass method
Rufus::Scheduler::Job#trigger
# File lib/rufus/scheduler/jobs_repeat.rb, line 71 def trigger(time) return if @paused_at #return set_next_time(time) if @paused_at return (@next_time = nil) if @times && @times < 1 return (@next_time = nil) if @last_at && time >= @last_at # # It keeps jobs one step too much in @jobs, but it's OK super @times -= 1 if @times end
Protected Instance Methods
discard_past?()
click to toggle source
# File lib/rufus/scheduler/jobs_repeat.rb, line 149 def discard_past? dp = @scheduler.discard_past dp = @discard_past if @discard_past != nil dp = @resume_discard_past if @resume_discard_past != nil dp end