class SidekiqScheduler::Config
Constants
- DEFAULT_OPTIONS
Attributes
scheduler_config[R]
sidekiq_config[R]
Public Class Methods
new(sidekiq_config: nil, without_defaults: false)
click to toggle source
We have to set the default as nil because the scheduler could be instantiated without passing the sidekiq config, and in those scenarios we don’t want to fail
# File lib/sidekiq-scheduler/config.rb, line 5 def initialize(sidekiq_config: nil, without_defaults: false) @sidekiq_config = sidekiq_config @scheduler_config = fetch_scheduler_config(sidekiq_config, without_defaults) end
Public Instance Methods
dynamic=(value)
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 22 def dynamic=(value) scheduler_config[:dynamic] = value end
dynamic?()
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 18 def dynamic? scheduler_config[:dynamic] end
dynamic_every=(value)
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 30 def dynamic_every=(value) scheduler_config[:dynamic_every] = value end
dynamic_every?()
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 26 def dynamic_every? scheduler_config[:dynamic_every] end
enabled=(value)
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 14 def enabled=(value) scheduler_config[:enabled] = value end
enabled?()
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 10 def enabled? scheduler_config[:enabled] end
listened_queues_only=(value)
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 46 def listened_queues_only=(value) scheduler_config[:listened_queues_only] = value end
listened_queues_only?()
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 42 def listened_queues_only? scheduler_config[:listened_queues_only] end
rufus_scheduler_options()
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 50 def rufus_scheduler_options scheduler_config[:rufus_scheduler_options] end
rufus_scheduler_options=(value)
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 54 def rufus_scheduler_options=(value) scheduler_config[:rufus_scheduler_options] = value end
schedule()
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 34 def schedule scheduler_config[:schedule] end
schedule=(value)
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 38 def schedule=(value) scheduler_config[:schedule] = value end
sidekiq_queues()
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 58 def sidekiq_queues SidekiqScheduler::SidekiqAdapter.sidekiq_queues(sidekiq_config) end
to_hash()
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 62 def to_hash { enabled: enabled?, dynamic: dynamic?, dynamic_every: dynamic_every?, schedule: schedule, listened_queues_only: listened_queues_only?, rufus_scheduler_options: rufus_scheduler_options } end
Private Instance Methods
fetch_scheduler_config(sidekiq_config, without_defaults)
click to toggle source
# File lib/sidekiq-scheduler/config.rb, line 86 def fetch_scheduler_config(sidekiq_config, without_defaults) conf = SidekiqScheduler::SidekiqAdapter.fetch_scheduler_config_from_sidekiq(sidekiq_config) without_defaults ? conf : DEFAULT_OPTIONS.merge(conf) end