class Dynflow::Config::QueuesConfig
Attributes
queues[R]
Public Class Methods
new()
click to toggle source
# File lib/dynflow/config.rb, line 52 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 61 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 68 def finalized_config(config_for_world) @queues.values.each do |queue_options| queue_options[:pool_size] ||= config_for_world.pool_size end @queues end