class Fluent::StdoutExOutput
Constants
- OUTPUT_PROCS
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_stdout_ex.rb, line 39 def configure(conf) super @output_proc = OUTPUT_PROCS[@output_type] @format_proc = if @format == "ltsv" Proc.new {|time, tag, record| "current_time:#{Time.now.localtime}\ttime:#{Time.at(time).localtime}\ttag:#{tag}\trecord:#{@output_proc.call(record)}\n" } else # [info]: is a fake ;-) Proc.new {|time, tag, record| "#{Time.now.localtime} [info]: #{Time.at(time).localtime} #{tag}: #{@output_proc.call(record)}\n" } end end
emit(tag, es, chain)
click to toggle source
# File lib/fluent/plugin/out_stdout_ex.rb, line 51 def emit(tag, es, chain) es.each {|time,record| $log.write @format_proc.call(time, tag, record) } $log.flush chain.next end