Class: Pgbus::QueuesController

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

Instance Method Summary collapse

Methods inherited from ApplicationController

#pgbus

Instance Method Details

#destroy ⇒ Object 



23
24
25
26
 
# File 'app/controllers/pgbus/queues_controller.rb', line 23

def destroy
  data_source.drop_queue(params[:name])
  redirect_to queues_path, notice: t("pgbus.queues.destroy.success", name: params[:name])
end

#discard_message ⇒ Object 



46
47
48
49
50
51
52
 
# File 'app/controllers/pgbus/queues_controller.rb', line 46

def discard_message
  if data_source.discard_job(params[:name], params[:msg_id])
    redirect_back fallback_location: queue_path(name: params[:name]), notice: t("pgbus.queues.show.message_discarded")
  else
    redirect_back fallback_location: queue_path(name: params[:name]), alert: t("pgbus.queues.show.message_discard_failed")
  end
end

#index ⇒ Object 



5
6
7
 
# File 'app/controllers/pgbus/queues_controller.rb', line 5

def index
  @queues = data_source.queues_with_metrics
end

#pause ⇒ Object 



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

def pause
  data_source.pause_queue(params[:name], reason: params[:reason])
  redirect_to queue_path(name: params[:name]), notice: "Queue paused."
end

#purge ⇒ Object 



18
19
20
21
 
# File 'app/controllers/pgbus/queues_controller.rb', line 18

def purge
  data_source.purge_queue(params[:name])
  redirect_to queue_path(name: params[:name]), notice: "Queue purged."
end

#resume ⇒ Object 



33
34
35
36
 
# File 'app/controllers/pgbus/queues_controller.rb', line 33

def resume
  data_source.resume_queue(params[:name])
  redirect_to queue_path(name: params[:name]), notice: "Queue resumed."
end

#retry_message ⇒ Object 



38
39
40
41
42
43
44
 
# File 'app/controllers/pgbus/queues_controller.rb', line 38

def retry_message
  if data_source.retry_job(params[:name], params[:msg_id])
    redirect_back fallback_location: queue_path(name: params[:name]), notice: t("pgbus.queues.show.message_retried")
  else
    redirect_back fallback_location: queue_path(name: params[:name]), alert: t("pgbus.queues.show.message_retry_failed")
  end
end

#show ⇒ Object 



9
10
11
12
13
14
15
16
 
# File 'app/controllers/pgbus/queues_controller.rb', line 9

def show
  @queue = data_source.queue_detail(params[:name])
  redirect_to queues_path, alert: "Queue not found." and return unless @queue

  @paused = data_source.queue_paused?(params[:name])
  @messages = data_source.jobs(queue_name: params[:name], page: page_param, per_page: per_page)
  @health = data_source.queue_health_detail(params[:name])
end