class SidekiqScheduler::SidekiqAdapter
Constants
- SIDEKIQ_GTE_7_3_0
- SIDEKIQ_GTE_8_0_0
Public Class Methods
Source
# File lib/sidekiq-scheduler/sidekiq_adapter.rb, line 6 def self.fetch_scheduler_config_from_sidekiq(sidekiq_config) return {} if sidekiq_config.nil? sidekiq_config.fetch(:scheduler, {}) end
Source
# File lib/sidekiq-scheduler/sidekiq_adapter.rb, line 29 def self.redis_key_exists?(key_name) Sidekiq.redis do |r| r.exists(key_name) > 0 end end
Source
# File lib/sidekiq-scheduler/sidekiq_adapter.rb, line 35 def self.redis_zrangebyscore(key, from, to) Sidekiq.redis do |r| r.zrange(key, from, to, "BYSCORE") end end
Source
# File lib/sidekiq-scheduler/sidekiq_adapter.rb, line 21 def self.sidekiq_queues(sidekiq_config) if sidekiq_config.nil? || (sidekiq_config.respond_to?(:empty?) && sidekiq_config.empty?) Sidekiq.instance_variable_get(:@config).queues.map(&:to_s) else sidekiq_config.queues.map(&:to_s) end end
Source
# File lib/sidekiq-scheduler/sidekiq_adapter.rb, line 12 def self.start_schedule_manager(sidekiq_config:, schedule_manager:) sidekiq_config[:schedule_manager] = schedule_manager sidekiq_config[:schedule_manager].start end
Source
# File lib/sidekiq-scheduler/sidekiq_adapter.rb, line 17 def self.stop_schedule_manager(sidekiq_config:) sidekiq_config[:schedule_manager].stop end