Class: SidekiqScheduler::Manager

Inherits:
Object
  • Object
show all
Includes:
Sidekiq::Util
Defined in:
lib/sidekiq-scheduler/manager.rb

Overview

The delayed job router in the system. This manages the scheduled jobs pushed messages from Redis onto the work queues

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ Manager

Returns a new instance of Manager.



17
18
19
20
21
22
 
# File 'lib/sidekiq-scheduler/manager.rb', line 17

def initialize(options)
  Sidekiq::Scheduler.enabled = options[:enabled]
  Sidekiq::Scheduler.dynamic = options[:dynamic]
  Sidekiq::Scheduler.listened_queues_only = options[:listened_queues_only]
  Sidekiq.schedule = options[:schedule] if Sidekiq::Scheduler.enabled
end

Instance Method Details

#reset ⇒ Object 



32
33
34
 
# File 'lib/sidekiq-scheduler/manager.rb', line 32

def reset
  clear_scheduled_work
end

#start ⇒ Object 



28
29
30
 
# File 'lib/sidekiq-scheduler/manager.rb', line 28

def start
  Sidekiq::Scheduler.load_schedule!
end

#stop ⇒ Object 



24
25
26
 
# File 'lib/sidekiq-scheduler/manager.rb', line 24

def stop
  Sidekiq::Scheduler.clear_schedule!
end