Module: Qmore::Reservers::Strategies::Sources

Defined in:
lib/qmore/reservers/strategies/sources.rb

Overview

This module provides the different kinds of queue sources used by qmore

Defined Under Namespace

Classes: Background

Class Method Summary collapse

Class Method Details

.direct(client) ⇒ Object

Direct source uses a client to generate the queues we should pull work from. Ignores any queues that do not have tasks available.



5
6
7
8
9
10
11
12
13
14
15
16
 
# File 'lib/qmore/reservers/strategies/sources.rb', line 5

def self.direct(client)
  Enumerator.new do |yielder|
    queues = client.queues.counts.reject do |queue|
      total = %w(waiting recurring depends stalled scheduled).inject(0) { |sum, state| sum += queue[state].to_i }
      total == 0
    end

    queues.each do |queue|
      yielder << client.queues[queue['name']]
    end
  end
end