lib/sidekiq/throttled/web.rb in sidekiq-throttled-0.18.0 vs lib/sidekiq/throttled/web.rb in sidekiq-throttled-1.0.0.alpha

- old
+ new

@@ -6,45 +6,24 @@ # 3rd party require "sidekiq" require "sidekiq/web" # internal -require "sidekiq/throttled/registry" -require "sidekiq/throttled/web/stats" -require "sidekiq/throttled/web/summary_fix" +require_relative "./registry" +require_relative "./web/stats" module Sidekiq module Throttled # Provides Sidekiq tab to monitor and reset throttled stats. module Web VIEWS = Pathname.new(__dir__).join("web") THROTTLED_TPL = VIEWS.join("throttled.html.erb").read.freeze - QUEUES_TPL = VIEWS.join("queues.html.erb").read.freeze class << self - # Replace default Queues tab with enhanced one. - def enhance_queues_tab! - SummaryFix.enabled = true - Sidekiq::Web::DEFAULT_TABS["Queues"] = "enhanced-queues" - Sidekiq::Web.tabs.delete("Enhanced Queues") - end - - # Restore original Queues tab. - # - # @api There's next to absolutely no value in this method for real - # users. The only it's purpose is to restore virgin state in specs. - def restore_queues_tab! - SummaryFix.enabled = false - Sidekiq::Web::DEFAULT_TABS["Queues"] = "queues" - Sidekiq::Web.tabs["Enhanced Queues"] = "enhanced-queues" - end - # @api private def registered(app) - SummaryFix.apply! app register_throttled_tab app - register_enhanced_queues_tab app end private def register_throttled_tab(app) @@ -53,34 +32,12 @@ app.post("/throttled/:id/reset") do Registry.get(params[:id], &:reset!) redirect "#{root_path}throttled" end end - - # rubocop:disable Metrics/AbcSize - def register_enhanced_queues_tab(app) # rubocop:disable Metrics/MethodLength - pauser = QueuesPauser.instance - - app.get("/enhanced-queues") do - @queues = Sidekiq::Queue.all - erb QUEUES_TPL.dup - end - - app.post("/enhanced-queues/:name") do - case params[:action] - when "delete" then Sidekiq::Queue.new(params[:name]).clear - when "pause" then pauser.pause!(params[:name]) - else pauser.resume!(params[:name]) - end - - redirect "#{root_path}enhanced-queues" - end - end - # rubocop:enable Metrics/AbcSize end end end end Sidekiq::Web.register Sidekiq::Throttled::Web Sidekiq::Web.tabs["Throttled"] = "throttled" -Sidekiq::Web.tabs["Enhanced Queues"] = "enhanced-queues"