class Fluent::TextParser::MultilineParser
Constants
- FORMAT_MAX_NUM
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
Fluent::Parser#configure
# File lib/fluent/parser.rb, line 547 def configure(conf) super formats = parse_formats(conf).compact.map { |f| f[1..-2] }.join begin @regex = Regexp.new(formats, Regexp::MULTILINE) if @regex.named_captures.empty? raise "No named captures" end @parser = RegexpParser.new(@regex, conf) rescue => e raise ConfigError, "Invalid regexp '#{formats}': #{e}" end if @format_firstline check_format_regexp(@format_firstline, 'format_firstline') @firstline_regex = Regexp.new(@format_firstline[1..-2]) end end
firstline?(text)
click to toggle source
# File lib/fluent/parser.rb, line 579 def firstline?(text) @firstline_regex.match(text) end
has_firstline?()
click to toggle source
# File lib/fluent/parser.rb, line 575 def has_firstline? !!@format_firstline end
parse(text, &block)
click to toggle source
# File lib/fluent/parser.rb, line 567 def parse(text, &block) if block @parser.call(text, &block) else @parser.call(text) end end
Private Instance Methods
check_format_range(conf)
click to toggle source
# File lib/fluent/parser.rb, line 602 def check_format_range(conf) invalid_formats = conf.keys.select { |k| m = k.match(/^format(\d+)$/) m ? !((1..FORMAT_MAX_NUM).include?(m[1].to_i)) : false } unless invalid_formats.empty? raise ConfigError, "Invalid formatN found. N should be 1 - #{FORMAT_MAX_NUM}: " + invalid_formats.join(",") end end
check_format_regexp(format, key)
click to toggle source
# File lib/fluent/parser.rb, line 612 def check_format_regexp(format, key) if format[0] == '/' && format[-1] == '/' begin Regexp.new(format[1..-2], Regexp::MULTILINE) rescue => e raise ConfigError, "Invalid regexp in #{key}: #{e}" end else raise ConfigError, "format should be Regexp, need //, in #{key}: '#{format}'" end end
parse_formats(conf)
click to toggle source
# File lib/fluent/parser.rb, line 585 def parse_formats(conf) check_format_range(conf) prev_format = nil (1..FORMAT_MAX_NUM).map { |i| format = conf["format#{i}"] if (i > 1) && prev_format.nil? && !format.nil? raise ConfigError, "Jump of format index found. format#{i - 1} is missing." end prev_format = format next if format.nil? check_format_regexp(format, "format#{i}") format } end