module Resque::JobHistoryServer
Extends Resque
Web Based UI. Structure has been borrowed from ResqueHistory.
Public Class Methods
erb_path(filename)
click to toggle source
# File lib/resque/job_history_server.rb, line 17 def erb_path(filename) File.join(File.dirname(__FILE__), "server", "views", filename) end
included(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 25 def included(base) add_page_views(base) add_button_callbacks(base) add_static_files(base) end
public_path(filename)
click to toggle source
# File lib/resque/job_history_server.rb, line 21 def public_path(filename) File.join(File.dirname(__FILE__), "server", "public", filename) end
Private Class Methods
add_page_views(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 33 def add_page_views(base) job_history(base) class_details(base) job_details(base) linear_list(base) end
add_static_files(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 131 def add_static_files(base) base.class_eval do get %r{/job_history/public/([a-z_]+\.[a-z]+)} do send_file Resque::JobHistoryServer.public_path(params[:captures].first) end end end
cancel_job(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 151 def cancel_job(base) base.class_eval do post "/job history/cancel_job" do Resque::Plugins::JobHistory::Job.new(params[:class_name], params[:job_id]).cancel redirect u("job history/job_details?#{{ class_name: params[:class_name], job_id: params[:job_id] }.to_param}") end end end
class_details(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 64 def class_details(base) class_details_params(base) running_page_params(base) finished_page_params(base) base.class_eval do get "/job history/job_class_details" do set_class_details_params erb File.read(Resque::JobHistoryServer.erb_path("job_class_details.erb")) end end end
class_details_params(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 78 def class_details_params(base) base.class_eval do def set_class_details_params @job_class_name = params[:class_name] set_running_page_params set_finished_page_params end end end
delete_job(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 162 def delete_job(base) base.class_eval do post "/job history/delete_job" do Resque::Plugins::JobHistory::Job.new(params[:class_name], params[:job_id]).purge redirect u("job history/job_class_details?#{{ class_name: params[:class_name] }.to_param}") end end end
finished_page_params(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 98 def finished_page_params(base) base.class_eval do def set_finished_page_params @finished_page_num = (params[:finished_page_num] || 1).to_i @finished_page_size = (params[:finished_page_size] || Resque::Plugins::JobHistory::HistoryDetails.new(@job_class_name).page_size).to_i end end end
job_details(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 108 def job_details(base) base.class_eval do get "/job history/job_details" do @job_class_name = params[:class_name] @job_id = params[:job_id] erb File.read(Resque::JobHistoryServer.erb_path("job_details.erb")) end end end
job_history(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 40 def job_history(base) job_history_params(base) base.class_eval do get "/job history" do set_job_history_params erb File.read(Resque::JobHistoryServer.erb_path("job_history.erb")) end end end
job_history_params(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 52 def job_history_params(base) base.class_eval do def set_job_history_params @sort_by = params[:sort] || "start_time" @sort_order = params[:order] || "desc" @page_num = (params[:page_num] || 1).to_i @page_size = (params[:page_size] || Resque::Plugins::JobHistory::HistoryDetails.class_list_page_size).to_i end end end
linear_list(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 119 def linear_list(base) base.class_eval do get "/job history/linear_history" do @page_num = (params[:page_num] || 1).to_i @page_size = (params[:page_size] || Resque::Plugins::JobHistory::HistoryDetails.linear_page_size).to_i erb File.read(Resque::JobHistoryServer.erb_path("linear_history.erb")) end end end
purge_all(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 192 def purge_all(base) base.class_eval do post "/job history/purge_all" do Resque::Plugins::JobHistory::Cleaner.purge_all_jobs redirect u("job history") end end end
purge_class(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 182 def purge_class(base) base.class_eval do post "/job history/purge_class" do Resque::Plugins::JobHistory::Cleaner.purge_class(params[:class_name]) redirect u("job history") end end end
purge_linear_history(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 202 def purge_linear_history(base) base.class_eval do post "/job history/purge_linear_history" do Resque::Plugins::JobHistory::Cleaner.purge_linear_history redirect u("job history") end end end
retry_job(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 172 def retry_job(base) base.class_eval do post "/job history/retry_job" do Resque::Plugins::JobHistory::Job.new(params[:class_name], params[:job_id]).retry redirect u("job history/job_class_details?#{{ class_name: params[:class_name] }.to_param}") end end end
running_page_params(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 88 def running_page_params(base) base.class_eval do def set_running_page_params @running_page_num = (params[:running_page_num] || 1).to_i @running_page_size = (params[:running_page_size] || Resque::Plugins::JobHistory::HistoryDetails.new(@job_class_name).page_size).to_i end end end
search_all(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 212 def search_all(base) base.class_eval do post "/job history/search_all" do @job_search = Resque::Plugins::JobHistory::JobSearch.new(params) @job_search.search erb File.read(Resque::JobHistoryServer.erb_path("search_results.erb")) end end end
search_job(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 224 def search_job(base) base.class_eval do post "/job history/search_job" do @job_search = Resque::Plugins::JobHistory::JobSearch.new(params) @job_search.search erb File.read(Resque::JobHistoryServer.erb_path("search_results.erb")) end end end
search_linear_history(base)
click to toggle source
# File lib/resque/job_history_server.rb, line 236 def search_linear_history(base) base.class_eval do post "/job history/search_linear_history" do @job_search = Resque::Plugins::JobHistory::JobSearch.new(params) @job_search.search erb File.read(Resque::JobHistoryServer.erb_path("search_results.erb")) end end end
set_class_details_params()
click to toggle source
# File lib/resque/job_history_server.rb, line 80 def set_class_details_params @job_class_name = params[:class_name] set_running_page_params set_finished_page_params end
set_finished_page_params()
click to toggle source
# File lib/resque/job_history_server.rb, line 100 def set_finished_page_params @finished_page_num = (params[:finished_page_num] || 1).to_i @finished_page_size = (params[:finished_page_size] || Resque::Plugins::JobHistory::HistoryDetails.new(@job_class_name).page_size).to_i end
set_job_history_params()
click to toggle source
# File lib/resque/job_history_server.rb, line 54 def set_job_history_params @sort_by = params[:sort] || "start_time" @sort_order = params[:order] || "desc" @page_num = (params[:page_num] || 1).to_i @page_size = (params[:page_size] || Resque::Plugins::JobHistory::HistoryDetails.class_list_page_size).to_i end
set_running_page_params()
click to toggle source
# File lib/resque/job_history_server.rb, line 90 def set_running_page_params @running_page_num = (params[:running_page_num] || 1).to_i @running_page_size = (params[:running_page_size] || Resque::Plugins::JobHistory::HistoryDetails.new(@job_class_name).page_size).to_i end