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