class Dynflow::Config::QueuesConfig

Attributes

queues[R]

Public Class Methods

new() click to toggle source
# File lib/dynflow/config.rb, line 54
def initialize
  @queues = { :default => {} }
end

Public Instance Methods

add(name, queue_options = {}) click to toggle source

Add a new queue to the configuration

@param [Hash] queue_options @option queue_options :pool_size The amount of workers available for the queue.

By default, it uses global pool_size config option.
# File lib/dynflow/config.rb, line 63
def add(name, queue_options = {})
  Utils.validate_keys!(queue_options, :pool_size)
  name = name.to_sym
  raise ArgumentError, "Queue #{name} is already defined" if @queues.key?(name)
  @queues[name] = queue_options
end
finalized_config(config_for_world) click to toggle source
# File lib/dynflow/config.rb, line 70
def finalized_config(config_for_world)
  @queues.values.each do |queue_options|
    queue_options[:pool_size] ||= config_for_world.pool_size
  end
  @queues
end