class

Kiq::Web::Action

Inherits Reference < Object

Constants

QUEUE_NAME = /\A[a-z_:.\-0-9]+\z/i
SESSION_COOKIE = "kiq.session"

Constructors

new(context : HTTP::Server::Context, route_params : Hash(String, String), nonce : String, decoded_path : String)
Source

Instance methods

base_url
Source
busy_create
Source
busy_index
Source
change_locale
Source
context
Source
dashboard
Source
dashboard_stats_redirect
Source
delete_or_add_queue(job : SortedEntry) : Nil
Source
halt(status : Int32, msg : String | Nil = nil) : NoReturn
Source
header(key : String, value : String) : Nil
Source
json(payload : String) : NoReturn
Source
metrics_index
Source
metrics_show
Source
morgue_bulk
Source
morgue_delete_all
Source
morgue_index
Source
morgue_retry_all
Source
morgue_show
Source
morgue_update
Source
nonce
Source
page_list(key : String, pageidx : String | Nil, page_size : Int32, reverse : Bool = false) : Tuple(Int32, Int64, Array(String))

Paginate a queue LIST (sidekiq Paginator#page, type "list").

Source
parse_key(key : String) : Tuple(Float64, String)

"score-jid" -> {score, jid}; garbage scores read as 0.0 (Ruby to_f).

Source
profile_data
Source
profile_show
Source
profiles_index
Source
queue_clear
Source
queue_delete_job
Source
queue_show
Source
queues_index
Source
redirect(location : String) : NoReturn
Source
redirect_to(url : String) : NoReturn

external redirect (no base_url prefix)

Source
redirect_with_query(url : String) : NoReturn

Any paginated list that performs an action needs to redirect back to the proper page after performing that action.

Source
reload_page
Source
request
Source
retries_bulk
Source
retries_delete_all
Source
retries_index
Source
retries_kill_all
Source
retries_retry_all
Source
retries_show
Source
retries_update
Source
retry_or_delete_or_kill(job : SortedEntry) : Nil
Source
root_heartbeat
Source
route_params
Source
run(block : Proc(Action, String)) : Nil
Source
scheduled_bulk
Source
scheduled_delete_all
Source
scheduled_enqueue_all
Source
scheduled_index
Source
scheduled_show
Source
scheduled_update
Source
search(jobset : JobSet, substr : String) : Array(SortedEntry)

Search helper (WebHelpers#search).

Source
stats_index
Source
stats_queues
Source
url_params(key : String) : String | Nil
Source