class Fluent::StatsitePlugin::StatsiteParser
Public Class Methods
new(on_message)
click to toggle source
# File lib/fluent/plugin/statsite/parser.rb, line 33 def initialize(on_message) @on_message = on_message end
Public Instance Methods
call(io)
click to toggle source
# File lib/fluent/plugin/statsite/parser.rb, line 37 def call(io) io.each_line(&method(:each_line)) end
each_line(line)
click to toggle source
# File lib/fluent/plugin/statsite/parser.rb, line 41 def each_line(line) time, record = parse_line(line) raise "out_statsite: failed to parse a line. '#{line}'" if record.nil? @on_message.call(time, record) end