class Fluent::Plugin::LabeledTSVParser

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method Fluent::Plugin::Parser#configure
# File lib/fluent/plugin/parser_ltsv.rb, line 33
def configure(conf)
  super
  @delimiter = @delimiter_pattern || @delimiter
end
parse(text) { |time, record| ... } click to toggle source
# File lib/fluent/plugin/parser_ltsv.rb, line 38
def parse(text)
  r = {}
  text.split(@delimiter).each do |pair|
    if pair.include? @label_delimiter
      key, value = pair.split(@label_delimiter, 2)
      r[key] = value
    end
  end
  time, record = convert_values(parse_time(r), r)
  yield time, record
end