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
23
 
# File 'lib/sidekiq-scheduler/manager.rb', line 17

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

Instance Method Details

#reset ⇒ Object 



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

def reset
  clear_scheduled_work
end

#start ⇒ Object 



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

def start
  SidekiqScheduler::Scheduler.load_schedule!
end

#stop ⇒ Object 



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

def stop
  SidekiqScheduler::Scheduler.clear_schedule!
end