Contents

module Sidekiq::QueueMetrics
  class Storage
    class << self
      def set_stats(key = stats_key, value)
        Sidekiq.redis_pool.with do |conn|
          conn.set(key, value)
        end
      end

      def get_stats(key = stats_key)
        Sidekiq.redis_pool.with do |conn|
          conn.get(key)
        end
      end

      def stats_key
        Sidekiq::QueueMetrics.storage_location || 'queue_stats'
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
sidekiq_queue_metrics-1.0	lib/sidekiq_queue_metrics/storage.rb
sidekiq_queue_metrics-0.0.4	lib/sidekiq_queue_metrics/storage.rb
sidekiq_queue_metrics-0.0.3	lib/sidekiq_queue_metrics/storage.rb
sidekiq_queue_metrics-0.0.2	lib/sidekiq_queue_metrics/storage.rb