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

Refactor set size fetch

This commit is contained in:
Mike Perham 2012-12-29 20:10:36 -08:00
parent 1785f02d1b
commit 9c9c5eef31
4 changed files with 14 additions and 13 deletions

View file

@ -1,6 +1,7 @@
HEAD
-----------
- Dashboard now live updates summary stats also. [brandonhilkert, #605]
- Add middleware chain APIs `insert_before` and `insert_after` for fine
tuning the order of middleware. [jackrg, #595]

View file

@ -33,6 +33,14 @@ module Sidekiq
queues.values.inject(&:+) || 0
end
def scheduled_size
Sidekiq.redis {|c| c.zcard('schedule') }
end
def retry_size
Sidekiq.redis {|c| c.zcard('retry') }
end
class History
def initialize(days_previous, start_date = nil)
@days_previous = days_previous

View file

@ -38,14 +38,6 @@ module Sidekiq
@stats ||= Sidekiq::Stats.new
end
def scheduled_job_count
Sidekiq::ScheduledSet.new.size
end
def retry_job_count
Sidekiq::RetrySet.new.size
end
def retries_with_score(score)
Sidekiq.redis do |conn|
results = conn.zrangebyscore('retry', score, score)
@ -204,7 +196,7 @@ module Sidekiq
end
get '/dashboard' do
@redis_info = Sidekiq.redis{ |conn| conn.info }
@redis_info = Sidekiq.redis { |conn| conn.info }
stats_history = Sidekiq::Stats::History.new((params[:days] || 30).to_i)
@processed_history = stats_history.processed
@failed_history = stats_history.failed
@ -218,8 +210,8 @@ module Sidekiq
processed: stats.processed,
failed: stats.failed,
enqueued: stats.enqueued,
scheduled: Sidekiq::ScheduledSet.new.size,
retries: Sidekiq::RetrySet.new.size
scheduled: stats.scheduled_size,
retries: stats.retry_size,
})
end

View file

@ -9,10 +9,10 @@ ul.unstyled.summary
span.count #{number_with_delimiter(workers.size)}
span.desc Busy
li.scheduled
span.count #{number_with_delimiter(scheduled_job_count)}
span.count #{number_with_delimiter(stats.scheduled_size)}
span.desc Scheduled
li.retries
span.count #{number_with_delimiter(retry_job_count)}
span.count #{number_with_delimiter(stats.retry_size)}
span.desc Retries
li.enqueued
span.count #{number_with_delimiter(stats.enqueued)}