lib/sidekiq-scheduler/sidekiq_adapter.rb
module SidekiqScheduler class SidekiqAdapter SIDEKIQ_GTE_7_3_0 = Gem::Version.new(Sidekiq::VERSION) >= Gem::Version.new('7.3.0') SIDEKIQ_GTE_8_0_0 = Gem::Version.new(Sidekiq::VERSION) >= Gem::Version.new('8.0.0') def self.fetch_scheduler_config_from_sidekiq(sidekiq_config) return {} if sidekiq_config.nil? sidekiq_config.fetch(:scheduler, {}) end def self.start_schedule_manager(sidekiq_config:, schedule_manager:) sidekiq_config[:schedule_manager] = schedule_manager sidekiq_config[:schedule_manager].start end def self.stop_schedule_manager(sidekiq_config:) sidekiq_config[:schedule_manager].stop end 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 def self.redis_key_exists?(key_name) Sidekiq.redis do |r| r.exists(key_name) > 0 end end def self.redis_zrangebyscore(key, from, to) Sidekiq.redis do |r| r.zrange(key, from, to, "BYSCORE") end end end end