Class: RoundhouseUi::QueuesController

Inherits:
ApplicationController show all
Defined in:
app/controllers/roundhouse_ui/queues_controller.rb

Constant Summary

Constants inherited from ApplicationController

ApplicationController::AUDIT_VERBS

Instance Method Summary collapse

Methods inherited from ApplicationController

#redirect_to

Instance Method Details

#index ⇒ Object 



5
6
7
8
9
 
# File 'app/controllers/roundhouse_ui/queues_controller.rb', line 5

def index
  @queues = Sidekiq::Queue.all
  @paused = RoundhouseUi::Pause.paused_set
  @fetch_installed = RoundhouseUi::Pause.fetch_installed?
end

#pause ⇒ Object 



17
18
19
20
 
# File 'app/controllers/roundhouse_ui/queues_controller.rb', line 17

def pause
  RoundhouseUi::Pause.pause!(params[:name])
  redirect_to queues_path, notice: "Paused “#{params[:name]}”."
end

#purge ⇒ Object

Real, OSS-supported destructive action: empties the queue in Redis.



12
13
14
15
 
# File 'app/controllers/roundhouse_ui/queues_controller.rb', line 12

def purge
  Sidekiq::Queue.new(params[:name]).clear
  redirect_to queues_path, notice: "Purged queue “#{params[:name]}”."
end

#resume ⇒ Object 



22
23
24
25
 
# File 'app/controllers/roundhouse_ui/queues_controller.rb', line 22

def resume
  RoundhouseUi::Pause.unpause!(params[:name])
  redirect_to queues_path, notice: "Resumed “#{params[:name]}”."
end

#snapshot ⇒ Object

Non-destructive backup — allowed even in read-only mode.



28
29
30
31
 
# File 'app/controllers/roundhouse_ui/queues_controller.rb', line 28

def snapshot
  snap = RoundhouseUi::Snapshots.take(params[:name])
  redirect_to queues_path, notice: "Snapshot saved — #{snap[:count]} job(s) from “#{params[:name]}”."
end