class SidekiqScheduler::Config
def dynamic=(value)
def dynamic=(value) scheduler_config[:dynamic] = value end
def dynamic?
def dynamic? scheduler_config[:dynamic] end
def dynamic_every=(value)
def dynamic_every=(value) scheduler_config[:dynamic_every] = value end
def dynamic_every?
def dynamic_every? scheduler_config[:dynamic_every] end
def enabled=(value)
def enabled=(value) scheduler_config[:enabled] = value end
def enabled?
def enabled? scheduler_config[:enabled] end
def fetch_scheduler_config(sidekiq_config, without_defaults)
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
def initialize(sidekiq_config: nil, without_defaults: false)
We have to set the default as nil because the scheduler could be instantiated without
def initialize(sidekiq_config: nil, without_defaults: false) @sidekiq_config = sidekiq_config @scheduler_config = fetch_scheduler_config(sidekiq_config, without_defaults) end
def listened_queues_only=(value)
def listened_queues_only=(value) scheduler_config[:listened_queues_only] = value end
def listened_queues_only?
def listened_queues_only? scheduler_config[:listened_queues_only] end
def rufus_scheduler_options
def rufus_scheduler_options scheduler_config[:rufus_scheduler_options] end
def rufus_scheduler_options=(value)
def rufus_scheduler_options=(value) scheduler_config[:rufus_scheduler_options] = value end
def schedule
def schedule scheduler_config[:schedule] end
def schedule=(value)
def schedule=(value) scheduler_config[:schedule] = value end
def sidekiq_queues
def sidekiq_queues SidekiqScheduler::SidekiqAdapter.sidekiq_queues(sidekiq_config) end
def to_hash
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