mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Add reset stats method to API
This commit is contained in:
parent
dc91e5d590
commit
4a0c3bbce1
2 changed files with 19 additions and 0 deletions
|
@ -16,6 +16,13 @@ module Sidekiq
|
||||||
count.nil? ? 0 : count.to_i
|
count.nil? ? 0 : count.to_i
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def reset
|
||||||
|
Sidekiq.redis do |conn|
|
||||||
|
conn.set("stat:failed", 0)
|
||||||
|
conn.set("stat:processed", 0)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
def queues
|
def queues
|
||||||
Sidekiq.redis do |conn|
|
Sidekiq.redis do |conn|
|
||||||
queues = conn.smembers('queues')
|
queues = conn.smembers('queues')
|
||||||
|
|
|
@ -32,6 +32,18 @@ class TestApi < MiniTest::Unit::TestCase
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
describe "reset" do
|
||||||
|
it 'can reset stats' do
|
||||||
|
Sidekiq.redis do |conn|
|
||||||
|
conn.set('stat:processed', 5)
|
||||||
|
conn.set('stat:failed', 10)
|
||||||
|
Sidekiq::Stats.new.reset
|
||||||
|
assert_equal '0', conn.get('stat:processed')
|
||||||
|
assert_equal '0', conn.get('stat:failed')
|
||||||
|
end
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
describe "queues" do
|
describe "queues" do
|
||||||
it "is initially empty" do
|
it "is initially empty" do
|
||||||
s = Sidekiq::Stats.new
|
s = Sidekiq::Stats.new
|
||||||
|
|
Loading…
Add table
Reference in a new issue