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

moved Queues to it's own section

This commit is contained in:
Fredrik Björk 2012-06-08 17:20:11 -07:00
parent 388c87accb
commit 83dd416d9e
4 changed files with 31 additions and 63 deletions

View file

@ -128,6 +128,11 @@ module Sidekiq
slim :index
end
get "/queues" do
@queues = queues
slim :queues
end
get "/queues/:name" do
halt 404 unless params[:name]
count = (params[:count] || 10).to_i
@ -146,7 +151,7 @@ module Sidekiq
conn.del("queue:#{params[:name]}")
conn.srem("queues", params[:name])
end
redirect root_path
redirect "#{root_path}queues"
end
get "/retries/:score" do

View file

@ -24,33 +24,20 @@ class TestWeb < MiniTest::Unit::TestCase
end
end
it 'shows active queues' do
it 'can display home' do
get '/'
assert_equal 200, last_response.status
assert_match /Sidekiq is idle/, last_response.body
refute_match /default/, last_response.body
assert WebWorker.perform_async(1, 2)
get '/'
assert_equal 200, last_response.status
assert_match /Sidekiq is idle/, last_response.body
assert_match /default/, last_response.body
refute_match /foo/, last_response.body
assert Sidekiq::Client.push('queue' => :foo, 'class' => WebWorker, 'args' => [1, 3])
get '/'
assert_equal 200, last_response.status
assert_match /Sidekiq is idle/, last_response.body
assert_match /default/, last_response.body
assert_match /foo/, last_response.body
assert_match /Backlog: 2/, last_response.body
end
it 'handles queues with no name' do
it 'can display queues' do
assert Sidekiq::Client.push('queue' => :foo, 'class' => WebWorker, 'args' => [1, 3])
get '/queues'
assert_equal 404, last_response.status
assert_equal 200, last_response.status
assert_match /foo/, last_response.body
refute_match /HardWorker/, last_response.body
end
it 'handles missing retry' do

View file

@ -1,4 +1,3 @@
.hero-unit
h1 Sidekiq is #{current_status}
p Processed: #{processed}
@ -8,44 +7,19 @@
p Retries Pending: #{zcard('retry')}
p Queue Backlog: #{backlog}
.tabbable
ul.nav.nav-tabs
li.active
a href="#workers" data-toggle="tab" Busy Workers
li
a href="#queues" data-toggle="tab" Queues
.tab-content
#workers.tab-pane.active
table class="table table-striped table-bordered"
tr
th Worker
th Queue
th Class
th Arguments
th Started
- workers.each do |(worker, msg)|
tr
td= worker
td= msg['queue']
td= msg['payload']['class']
td= msg['payload']['args'].inspect[0..100]
td== relative_time(Time.parse(msg['run_at']))
form action="#{root_path}reset" method="post"
button.btn type="submit" title="If you kill -9 Sidekiq, this table can fill up with old data." Clear worker list
#queues.tab-pane
table class="table table-striped table-bordered"
tr
th Queue
th Size
th
- queues.each do |(queue, size)|
tr
td
a href="#{root_path}queues/#{queue}" #{queue}
td= size
td
form action="#{root_path}queues/#{queue}" method="post"
input.btn.btn-danger type="submit" name="delete" value="Delete"
table class="table table-striped table-bordered"
tr
th Worker
th Queue
th Class
th Arguments
th Started
- workers.each do |(worker, msg)|
tr
td= worker
td= msg['queue']
td= msg['payload']['class']
td= msg['payload']['args'].inspect[0..100]
td== relative_time(Time.parse(msg['run_at']))
form action="#{root_path}reset" method="post"
button.btn type="submit" title="If you kill -9 Sidekiq, this table can fill up with old data." Clear worker list

View file

@ -12,6 +12,8 @@ html
ul.nav
li
a href='#{{root_path}}' Home
li
a href='#{{root_path}}queues' Queues
li
a href='#{{root_path}}retries' Retries
li