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