Class: SolidQueueTui::Data::QueuesQuery

Inherits:
Object
  • Object
show all
Defined in:
lib/solid_queue_tui/data/queues_query.rb

Defined Under Namespace

Classes: QueueInfo

Class Method Summary collapse

Class Method Details

.fetch ⇒ Object 



11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/solid_queue_tui/data/queues_query.rb', line 11

def self.fetch
  queues = SolidQueue::Queue.all
  pauses = SolidQueue::Pause.where(queue_name: queues.map(&:name)).index_by(&:queue_name)

  queues.map do |queue|
    QueueInfo.new(
      name: queue.name,
      size: queue.size,
      paused: pauses[queue.name].present?
    )
  end
rescue => e
  []
end