mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Add worker info to summary update.
This commit is contained in:
parent
86f2bba121
commit
bbff51ac2a
4 changed files with 22 additions and 5 deletions
|
@ -220,6 +220,7 @@ module Sidekiq
|
|||
sidekiq: {
|
||||
processed: sidekiq_stats.processed,
|
||||
failed: sidekiq_stats.failed,
|
||||
busy: workers.size,
|
||||
enqueued: sidekiq_stats.enqueued,
|
||||
scheduled: sidekiq_stats.scheduled_size,
|
||||
retries: sidekiq_stats.retry_size,
|
||||
|
|
|
@ -207,6 +207,8 @@ class TestWeb < MiniTest::Unit::TestCase
|
|||
end
|
||||
2.times { add_retry }
|
||||
3.times { add_scheduled }
|
||||
4.times { add_worker }
|
||||
|
||||
get '/dashboard/stats'
|
||||
@response = Sidekiq.load_json(last_response.body)
|
||||
end
|
||||
|
@ -221,19 +223,23 @@ class TestWeb < MiniTest::Unit::TestCase
|
|||
end
|
||||
|
||||
it 'reports processed' do
|
||||
assert_equal @response["sidekiq"]["processed"], 5
|
||||
assert_equal 5, @response["sidekiq"]["processed"]
|
||||
end
|
||||
|
||||
it 'reports failed' do
|
||||
assert_equal @response["sidekiq"]["failed"], 2
|
||||
assert_equal 2, @response["sidekiq"]["failed"]
|
||||
end
|
||||
|
||||
it 'reports busy' do
|
||||
assert_equal 4, @response["sidekiq"]["busy"]
|
||||
end
|
||||
|
||||
it 'reports retries' do
|
||||
assert_equal @response["sidekiq"]["retries"], 2
|
||||
assert_equal 2, @response["sidekiq"]["retries"]
|
||||
end
|
||||
|
||||
it 'reports scheduled' do
|
||||
assert_equal @response["sidekiq"]["scheduled"], 3
|
||||
assert_equal 3, @response["sidekiq"]["scheduled"]
|
||||
end
|
||||
end
|
||||
|
||||
|
@ -271,5 +277,14 @@ class TestWeb < MiniTest::Unit::TestCase
|
|||
end
|
||||
[msg, score]
|
||||
end
|
||||
|
||||
def add_worker
|
||||
process_id = rand(1000)
|
||||
msg = "{\"queue\":\"default\",\"payload\":{\"retry\":true,\"queue\":\"default\",\"timeout\":20,\"backtrace\":5,\"class\":\"HardWorker\",\"args\":[\"bob\",10,5],\"jid\":\"2b5ad2b016f5e063a1c62872\"},\"run_at\":1361208995}"
|
||||
Sidekiq.redis do |conn|
|
||||
conn.sadd("workers", "mercury.home:#{process_id}-70215157189060:started")
|
||||
conn.set("worker:mercury.home:#{process_id}-70215157189060:started", msg)
|
||||
end
|
||||
end
|
||||
end
|
||||
end
|
||||
|
|
|
@ -114,6 +114,7 @@ var createSeries = function(obj) {
|
|||
var updateStatsSummary = function(data) {
|
||||
$('ul.summary li.processed span.count').html(data.processed.numberWithDelimiter())
|
||||
$('ul.summary li.failed span.count').html(data.failed.numberWithDelimiter())
|
||||
$('ul.summary li.busy span.count').html(data.busy.numberWithDelimiter())
|
||||
$('ul.summary li.scheduled span.count').html(data.scheduled.numberWithDelimiter())
|
||||
$('ul.summary li.retries span.count').html(data.retries.numberWithDelimiter())
|
||||
$('ul.summary li.enqueued span.count').html(data.enqueued.numberWithDelimiter())
|
||||
|
|
|
@ -5,7 +5,7 @@ ul.unstyled.summary
|
|||
li.failed
|
||||
span.count #{number_with_delimiter(stats.failed)}
|
||||
span.desc Failed
|
||||
li
|
||||
li.busy
|
||||
span.count #{number_with_delimiter(workers.size)}
|
||||
span.desc Busy
|
||||
li.scheduled
|
||||
|
|
Loading…
Add table
Reference in a new issue