class Fluent::Plugin::CopyOutput
Public Instance Methods
multi_workers_ready?()
click to toggle source
# File lib/fluent/plugin/out_copy.rb, line 28 def multi_workers_ready? true end
process(tag, es)
click to toggle source
# File lib/fluent/plugin/out_copy.rb, line 32 def process(tag, es) unless es.repeatable? m = Fluent::MultiEventStream.new es.each {|time,record| m.add(time, record) } es = m end outputs.each do |output| output.emit_events(tag, @deep_copy ? es.dup : es) end end