Class: Sidekiq::Dejavu::Manager

Inherits:
Object
  • Object
show all
Includes:
Helper
Defined in:
lib/sidekiq/dejavu/manager.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Helper

#next_randomized_timestamp, #next_timestamp, #valid_cron?

Constructor Details

#initialize(schedules = {}, scheduled_set = Sidekiq::ScheduledSet.new) ⇒ Manager 



8
9
10
11
 
# File 'lib/sidekiq/dejavu/manager.rb', line 8

def initialize(schedules = {}, scheduled_set = Sidekiq::ScheduledSet.new)
  @schedules = schedules
  @scheduled_set = scheduled_set
end

Instance Attribute Details

#scheduled_set ⇒ Object

Returns the value of attribute scheduled_set.



6
7
8
 
# File 'lib/sidekiq/dejavu/manager.rb', line 6

def scheduled_set
  @scheduled_set
end

#schedules ⇒ Object

Returns the value of attribute schedules.



6
7
8
 
# File 'lib/sidekiq/dejavu/manager.rb', line 6

def schedules
  @schedules
end

Instance Method Details

#reload_schedule! ⇒ Object 



13
14
15
16
 
# File 'lib/sidekiq/dejavu/manager.rb', line 13

def reload_schedule!
  clear_changed_schedules
  add_new_schedules
end

#scheduled_jobs ⇒ Object 



18
19
20
 
# File 'lib/sidekiq/dejavu/manager.rb', line 18

def scheduled_jobs
  scheduled_set.select { |job| job.item.has_key? 'schedule' }
end