Class/Module Index [+]

Quicksearch

Fluent::ExecFilterOutput::TSVParser

Public Class Methods

new(out_keys, on_message) click to toggle source
# File lib/fluent/plugin/out_exec_filter.rb, line 402
def initialize(out_keys, on_message)
  @out_keys = out_keys
  super(on_message)
end

Public Instance Methods

call(io) click to toggle source
# File lib/fluent/plugin/out_exec_filter.rb, line 407
def call(io)
  io.each_line(&method(:each_line))
end
each_line(line) click to toggle source
# File lib/fluent/plugin/out_exec_filter.rb, line 411
def each_line(line)
  line.chomp!
  vals = line.split("\t")

  record = Hash[@out_keys.zip(vals)]

  @on_message.call(record)
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.