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