Class: SidekiqScheduler::Manager

Inherits:
Object
  • Object
show all
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

Constant Summary collapse

DEFAULT_SCHEDULER_OPTIONS = 
{
  enabled: true,
  dynamic: false,
  dynamic_every: '5s',
  schedule: {}
}

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ Manager

Returns a new instance of Manager.



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

def initialize(options)
  scheduler_options = load_scheduler_options(options)

  @scheduler_instance = SidekiqScheduler::Scheduler.new(scheduler_options)
  SidekiqScheduler::Scheduler.instance = @scheduler_instance
  Sidekiq.schedule = scheduler_options[:schedule] if @scheduler_instance.enabled
end

Instance Method Details

#start ⇒ Object 



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

def start
  @scheduler_instance.load_schedule!
end

#stop ⇒ Object 



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

def stop
  @scheduler_instance.clear_schedule!
end