Module: Fluentd::Setting::SectionConfig

Extended by:
ActiveSupport::Concern
Defined in:
app/models/concerns/fluentd/setting/section_config.rb

Instance Method Summary collapse

Instance Method Details

#config_element(name = 'test', argument = '', params = {}, elements = []) ⇒ Object

copy from Fluent::Test::Helpers#config_element



46
47
48
 
# File 'app/models/concerns/fluentd/setting/section_config.rb', line 46

def config_element(name = 'test', argument = '', params = {}, elements = [])
  Fluent::Config::Element.new(name, argument, params, elements)
end

#parse_attributes(attributes) ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'app/models/concerns/fluentd/setting/section_config.rb', line 19

def parse_attributes(attributes)
  sections, params = attributes.partition do |key, _|
    self._sections.key?(key.to_sym)
  end
  elements = sections.map do |key, section_params|
    if section_params.present?
      section_class = self._sections[key.to_sym]
      if section_class.multi?
        section_params.map do |index, _section_params|
          section_class.new(_section_params).to_config
        end
      else
        section_class.new(section_params).to_config
      end
    end
  end
  elements = elements.flatten.compact
  attrs = params.to_h.reject do |key, value|
    skip?(key.to_sym, value)
  end
  unless attrs.blank?
    attrs["@type"] = params.to_h["@type"] if params.to_h.key?("@type")
  end
  return attrs, elements
end

#skip?(key, value) ⇒ Boolean

Returns:

  • (Boolean) 


50
51
52
53
54
55
56
57
 
# File 'app/models/concerns/fluentd/setting/section_config.rb', line 50

def skip?(key, value)
  return true if value.blank?
  if self._defaults.key?(key)
    self.class.reformat_value(key, self._defaults[key]) == self.class.reformat_value(key, value)
  else
    false
  end
end

#to_config ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
 
# File 'app/models/concerns/fluentd/setting/section_config.rb', line 6

def to_config
  _attributes = attributes.dup
  if i(parse format buffer storage).include?(section_name)
    _attributes["@type"] = _attributes.delete("type")
    _attributes["@log_level"] = _attributes.delete("log_level")
  end
  argument = _attributes.delete(self._argument_name.to_s) || ""
  attrs, elements = parse_attributes(_attributes)
  if attrs.present? || elements.present?
    config_element(section_name, argument, attrs.sort.to_h, elements)
  end
end