Sha256: 8dc276883ad614ef37d6508342d1e66906a82a2b6d6dced30b9f02a134de053a
Contents?: true
Size: 1.72 KB
Versions: 7
Compression:
Stored size: 1.72 KB
Contents
require 'sidekiq/web'
module Sidetiq
module Web
VIEWS = File.expand_path('views', File.dirname(__FILE__))
def self.registered(app)
app.get "/sidetiq" do
@workers = Sidetiq.workers
@time = Sidetiq.clock.gettime
erb File.read(File.join(VIEWS, 'sidetiq.erb'))
end
app.get "/sidetiq/locks" do
@locks = Sidetiq::Lock::Redis.all.map(&:meta_data)
erb File.read(File.join(VIEWS, 'locks.erb'))
end
app.get "/sidetiq/:name/schedule" do
halt 404 unless (name = params[:name])
@time = Sidetiq.clock.gettime
@worker = Sidetiq.workers.detect do |worker|
worker.name == name
end
@schedule = @worker.schedule
erb File.read(File.join(VIEWS, 'schedule.erb'))
end
app.get "/sidetiq/:name/history" do
halt 404 unless (name = params[:name])
@time = Sidetiq.clock.gettime
@worker = Sidetiq.workers.detect do |worker|
worker.name == name
end
@history = Sidekiq.redis do |redis|
redis.lrange("sidetiq:#{name}:history", 0, -1)
end
erb File.read(File.join(VIEWS, 'history.erb'))
end
app.post "/sidetiq/:name/trigger" do
halt 404 unless (name = params[:name])
worker = Sidetiq.workers.detect do |worker|
worker.name == name
end
worker.perform_async
redirect "#{root_path}sidetiq"
end
app.post "/sidetiq/:name/unlock" do
halt 404 unless (name = params[:name])
Sidetiq::Lock::Redis.new(name).unlock!
redirect "#{root_path}sidetiq/locks"
end
end
end
end
Sidekiq::Web.register(Sidetiq::Web)
Sidekiq::Web.tabs["Sidetiq"] = "sidetiq"
Version data entries
7 entries across 7 versions & 1 rubygems