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

* Memoize stats instance

* Create more indicative helpers for stats
* Update example for Stats API
This commit is contained in:
Brandon Hilkert 2012-12-05 11:46:55 -05:00
parent 005ebcf13d
commit 355cc3f604
3 changed files with 14 additions and 17 deletions

View file

@ -19,8 +19,9 @@ class SinatraWorker
end
get '/' do
@failed = Sidekiq.info[:failed]
@processed = Sidekiq.info[:processed]
stats = Sidekiq::Stats.new
@failed = stats.failed
@processed = stats.processed
@messages = $redis.lrange('sinkiq-example-messages', 0, -1)
erb :index
end

View file

@ -34,20 +34,16 @@ module Sidekiq
end
end
def processed
Sidekiq::Stats.new.processed
def stats
@stats ||= Sidekiq::Stats.new
end
def failed
Sidekiq::Stats.new.failed
def scheduled_job_count
Sidekiq::ScheduledSet.new.size
end
def zcard(name)
Sidekiq.redis { |conn| conn.zcard(name) }
end
def enqueued
Sidekiq::Stats.new.enqueued
def retry_job_count
Sidekiq::RetrySet.new.size
end
def retries_with_score(score)

View file

@ -1,19 +1,19 @@
ul.unstyled.summary
li
span.count #{number_with_delimiter(processed)}
span.count #{number_with_delimiter(stats.processed)}
span.desc Processed
li
span.count #{number_with_delimiter(failed)}
span.count #{number_with_delimiter(stats.failed)}
span.desc Failed
li
span.count #{number_with_delimiter(workers.size)}
span.desc Busy
li
span.count #{number_with_delimiter(zcard('schedule'))}
span.count #{number_with_delimiter(scheduled_job_count)}
span.desc Scheduled
li
span.count #{number_with_delimiter(zcard('retry'))}
span.count #{number_with_delimiter(retry_job_count)}
span.desc Retries
li
span.count #{number_with_delimiter(enqueued)}
span.count #{number_with_delimiter(stats.enqueued)}
span.desc Enqueued