Add retries data to Web UI

lib/sidekiq/web.rb

@@ -56,6 +56,17 @@ module Sidekiq
         Sidekiq.redis { |conn| conn.get('stat:failed') } || 0
       end
 
+      def retry_count
+        Sidekiq.redis { |conn| conn.zcard('retry') }
+      end
+
+      def retries
+        Sidekiq.redis do |conn|
+          results = conn.zrange('retry', 0, 25, :withscores => true)
+          results.each_slice(2).to_a.map { |x| [MultiJson.decode(x[0]), Float(x[1])] }
+        end
+      end
+
       def queues
         Sidekiq.redis do |conn|
           conn.smembers('queues').map do |q|

web/views/index.slim

@@ -4,6 +4,7 @@
   p Processed: #{processed}
   p Failed: #{failed}
   p Workers: #{workers.size}
+  p Retries Pending: #{retry_count}
 
 .tabbable
   ul.nav.nav-tabs
@@ -11,6 +12,8 @@
       a href="#workers" data-toggle="tab" Workers
     li
       a href="#queues" data-toggle="tab" Queues
+    li
+      a href="#retries" data-toggle="tab" Retries
   .tab-content
     #workers.tab-pane.active
       table class="table table-striped table-bordered"
@@ -40,3 +43,20 @@
               a href="queues/#{queue}" #{queue}
             td= size
 
+    #retries.tab-pane
+      table class="table table-striped table-bordered"
+        tr
+          th Next Retry
+          th Retry Count
+          th Queue
+          th Worker
+          th Args
+        - retries.each do |(msg, score)|
+          tr
+            td= Time.at(score)
+            td= msg['retry_count']
+            td
+              a href="queues/#{msg['queue']}" #{msg['queue']}
+            td= msg['class']
+            td= msg['args'].inspect[0..100]
+