kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

Implement Sidekiq::Stats.failed

Browse source
This commit is contained in:
jc00ke 2012-09-03 10:43:08 -07:00
parent ec4833b0da
commit 7574bb1756
4 changed files with 11 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
examples/sinkiq.rb
View file

@ -19,7 +19,7 @@ class SinatraWorker
end
get '/' do
@failed = $redis.get('stat:failed')
@failed = Sidekiq::Stats.failed
@processed = Sidekiq::Stats.processed
@messages = $redis.lrange('sinkiq-example-messages', 0, -1)
erb :index

6
lib/sidekiq/stats.rb
View file

@ -3,7 +3,11 @@ module Sidekiq
module_function
def processed
Sidekiq.redis { |conn| conn.get('stat:processed') }.to_i || 0
(Sidekiq.redis { |conn| conn.get('stat:processed') } || 0).to_i
end
def failed
(Sidekiq.redis { |conn| conn.get('stat:failed') } || 0).to_i
end
end
end

2
lib/sidekiq/web.rb
View file

@ -65,7 +65,7 @@ module Sidekiq
end
def failed
Sidekiq.redis { |conn| conn.get('stat:failed') } || 0
Sidekiq::Stats.failed
end
def zcard(name)

8
test/test_stats.rb
View file

@ -31,14 +31,14 @@ class TestStats < MiniTest::Unit::TestCase
boss.expect(:processor_done!, nil, [processor])
boss.expect(:processor_done!, nil, [processor])
assert_equal 0, conn.get('stat:failed').to_i
assert_equal 0, Sidekiq::Stats.failed
assert_equal 0, Sidekiq::Stats.processed
processor.process(msg, 'xyzzy')
processor.process(msg, 'xyzzy')
processor.process(msg, 'xyzzy')
assert_equal 0, conn.get('stat:failed').to_i
assert_equal 0, Sidekiq::Stats.failed
assert_equal 3, Sidekiq::Stats.processed
end
end
@ -49,7 +49,7 @@ class TestStats < MiniTest::Unit::TestCase
@redis.with do |conn|
assert_equal [], conn.smembers('workers')
assert_equal 0, conn.get('stat:failed').to_i
assert_equal 0, Sidekiq::Stats.failed
assert_equal 0, Sidekiq::Stats.processed
processor = Sidekiq::Processor.new(boss)
@ -59,7 +59,7 @@ class TestStats < MiniTest::Unit::TestCase
processor.process(msg, 'xyzzy')
end
assert_equal 1, conn.get('stat:failed').to_i
assert_equal 1, Sidekiq::Stats.failed
assert_equal 1, Sidekiq::Stats.processed
end
end