class Fluent::ToSOutput
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_to_s.rb, line 7 def configure(conf) super @tag_proc = Proc.new {|tag| "#{@tag_prefix}.#{tag}"} end
emit(tag, es, chain)
click to toggle source
# File lib/fluent/plugin/out_to_s.rb, line 13 def emit(tag, es, chain) emit_tag = @tag_proc.call(tag) es.each do |time, record| record[@field_name] = record.to_s Fluent::Engine.emit(emit_tag, time, record) end chain.next end