Method: Fluent::Plugin::ExecInput#configure

Defined in:
lib/fluent/plugin/in_exec.rb

#configure(conf) ⇒ Object



51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
# File 'lib/fluent/plugin/in_exec.rb', line 51

def configure(conf)
  compat_parameters_convert(conf, :extract, :parser)
  ['parse', 'extract'].each do |subsection_name|
    if subsection = conf.elements(subsection_name).first
      if subsection.has_key?('time_format')
        subsection['time_type'] ||= 'string'
      end
    end
  end

  super

  if !@tag && (!@extract_config || !@extract_config.tag_key)
    raise Fluent::ConfigError, "'tag' or 'tag_key' option is required on exec input"
  end
  @parser = parser_create
end