class Fluent::Compat::ExecUtil::TextParserWrapperParser

Public Class Methods

new(conf, on_message) click to toggle source
Calls superclass method Fluent::Compat::ExecUtil::Parser::new
# File lib/fluent/compat/exec_util.rb, line 40
def initialize(conf, on_message)
  @parser = Plugin.new_parser(conf['format'])
  @parser.configure(conf)
  super(on_message)
end

Public Instance Methods

call(io) click to toggle source
# File lib/fluent/compat/exec_util.rb, line 46
def call(io)
  io.each_line(&method(:each_line))
end
each_line(line) click to toggle source
# File lib/fluent/compat/exec_util.rb, line 50
def each_line(line)
  line.chomp!
  @parser.parse(line) { |time, record|
    @on_message.call(record, time)
  }
end