# File lib/fluent/plugin/out_test.rb, line 59 def configure(conf) if name = conf['name'] @name = name end end
# File lib/fluent/plugin/out_test.rb, line 71 def emit(tag, es, chain) chain.next @emit_streams << [tag, es.to_a] end
# File lib/fluent/plugin/out_test.rb, line 31 def emits all = [] @emit_streams.each {|tag,events| events.each {|time,record| all << [tag, time, record] } } all end
# File lib/fluent/plugin/out_test.rb, line 41 def events all = [] @emit_streams.each {|tag,events| all.concat events } all end
Generated with the Darkfish Rdoc Generator 2.