module AtomicSidekiq::Web
Constants
- VIEW_PATH
Public Class Methods
register_delete_inflight(app)
click to toggle source
# File lib/atomic_sidekiq/web.rb, line 26 def self.register_delete_inflight(app) app.post "/in-flight/:jid/delete" do AtomicSidekiq::InFlightQueue.new.delete_job(route_params[:jid]) redirect "#{root_path}in-flight" end end
register_inflight(app)
click to toggle source
# File lib/atomic_sidekiq/web.rb, line 11 def self.register_inflight(app) app.get "/in-flight" do @jobs = AtomicSidekiq::InFlightQueue.new.list @total_size = @jobs.count @count = (params[:count] || 25).to_i @current_page = (params[:page] || 1).to_i start_idx = (@current_page - 1) * @count end_idx = (@current_page * @count) - 1 @jobs = @jobs[start_idx..end_idx] || [] erb File.read(File.join(VIEW_PATH, "in_flight.erb")) end end
register_recovered(app)
click to toggle source
# File lib/atomic_sidekiq/web.rb, line 34 def self.register_recovered(app) app.get "/recovered" do @queues = AtomicSidekiq::RecoveredStats.new.stats_by_queue @jobs = AtomicSidekiq::RecoveredStats.new.stats_by_job erb File.read(File.join(VIEW_PATH, "recovered.erb")) end end
registered(app)
click to toggle source
# File lib/atomic_sidekiq/web.rb, line 5 def self.registered(app) register_inflight(app) register_delete_inflight(app) register_recovered(app) end