module Fluent::Config::SectionGenerator
Public Class Methods
check_unused_section(proxy, conf, plugin_class)
click to toggle source
# File lib/fluent/config/section.rb, line 150 def self.check_unused_section(proxy, conf, plugin_class) elems = conf.respond_to?(:elements) ? conf.elements : [] elems.each { |e| next if plugin_class.nil? && Fluent::Config::V1Parser::ELEM_SYMBOLS.include?(e.name) # skip pre-defined non-plugin elements because it doens't have proxy section unless proxy.sections.any? { |name, subproxy| e.name == subproxy.name.to_s || e.name == subproxy.alias.to_s } parent_name = if conf.arg.empty? conf.name else "#{conf.name} #{conf.arg}" end e.unused_in = [parent_name, plugin_class] end } end
generate(proxy, conf, logger, plugin_class, stack = [])
click to toggle source
# File lib/fluent/config/section.rb, line 79 def self.generate(proxy, conf, logger, plugin_class, stack = []) return nil if conf.nil? section_stack = "" unless stack.empty? section_stack = ", in section " + stack.join(" > ") end section_params = {} proxy.defaults.each_pair do |name, defval| varname = name.to_sym section_params[varname] = defval end if proxy.argument unless conf.arg.empty? key, block, opts = proxy.argument section_params[key] = self.instance_exec(conf.arg, opts, name, &block) end unless section_params.has_key?(proxy.argument.first) logger.error "config error in:\n#{conf}" raise ConfigError, "'<#{proxy.name} ARG>' section requires argument" + section_stack end end proxy.params.each_pair do |name, defval| varname = name.to_sym block, opts = defval if conf.has_key?(name.to_s) || opts[:alias] && conf.has_key?(opts[:alias].to_s) val = if conf.has_key?(name.to_s) conf[name.to_s] else conf[opts[:alias].to_s] end section_params[varname] = self.instance_exec(val, opts, name, &block) end unless section_params.has_key?(varname) logger.error "config error in:\n#{conf}" raise ConfigError, "'#{name}' parameter is required" + section_stack end end check_unused_section(proxy, conf, plugin_class) proxy.sections.each do |name, subproxy| varname = subproxy.param_name.to_sym elements = (conf.respond_to?(:elements) ? conf.elements : []).select{ |e| e.name == subproxy.name.to_s || e.name == subproxy.alias.to_s } # set subproxy for secret option elements.each { |element| element.corresponding_proxies << subproxy } if subproxy.required? && elements.size < 1 logger.error "config error in:\n#{conf}" raise ConfigError, "'<#{subproxy.name}>' sections are required" + section_stack end if subproxy.multi? section_params[varname] = elements.map{ |e| generate(subproxy, e, logger, plugin_class, stack + [subproxy.name]) } else if elements.size > 1 logger.error "config error in:\n#{conf}" raise ConfigError, "'<#{subproxy.name}>' section cannot be written twice or more" + section_stack end section_params[varname] = generate(subproxy, elements.first, logger, plugin_class, stack + [subproxy.name]) end end Section.new(section_params) end