mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
simple reset button on sidekiq monitoring page to remove list of workers from redis
This commit is contained in:
parent
b424508be1
commit
1b2a2a2d7d
2 changed files with 18 additions and 0 deletions
|
@ -36,6 +36,17 @@ module Sidekiq
|
|||
use SprocketsMiddleware, :root => dir
|
||||
|
||||
helpers do
|
||||
|
||||
def reset_worker_list
|
||||
Sidekiq.redis do |conn|
|
||||
workers = conn.smembers('workers')
|
||||
workers.each do |name|
|
||||
conn.srem('workers', name) # if name =~ /:#{process_id}-/
|
||||
end
|
||||
end
|
||||
|
||||
end
|
||||
|
||||
def workers
|
||||
@workers ||= begin
|
||||
Sidekiq.redis do |conn|
|
||||
|
@ -94,6 +105,11 @@ module Sidekiq
|
|||
slim :index
|
||||
end
|
||||
|
||||
post "/reset" do
|
||||
reset_worker_list
|
||||
redirect '/sidekiq'
|
||||
end
|
||||
|
||||
get "/queues/:name" do
|
||||
halt 404 unless params[:name]
|
||||
@name = params[:name]
|
||||
|
|
|
@ -5,6 +5,8 @@
|
|||
p Failed: #{failed}
|
||||
p Workers: #{workers.size}
|
||||
p Retries Pending: #{retry_count}
|
||||
form(action="/sidekiq/reset" method="post")
|
||||
button(class="btn" type="submit") Clear worker list
|
||||
|
||||
.tabbable
|
||||
ul.nav.nav-tabs
|
||||
|
|
Loading…
Add table
Reference in a new issue