lib/sidekiq/api.rb in sidekiq-2.17.1 vs lib/sidekiq/api.rb in sidekiq-2.17.2
- old
+ new
@@ -8,13 +8,15 @@
def failed
Sidekiq.redis { |conn| conn.get("stat:failed") }.to_i
end
- def reset
+ def reset(*stats)
+ all = %w(failed processed)
+ stats = stats.empty? ? all : all & stats.flatten.compact.map(&:to_s)
+
Sidekiq.redis do |conn|
- conn.set("stat:failed", 0)
- conn.set("stat:processed", 0)
+ stats.each { |stat| conn.set("stat:#{stat}", 0) }
end
end
def queues
Sidekiq.redis do |conn|