Object
# File lib/fluent/process.rb, line 268 def initialize(forwarders) @forwarders = forwarders @rr = 1 end
# File lib/fluent/process.rb, line 273 def emit(tag, es) forwarder = @forwarders[@rr] @rr = (@rr + 1) % @forwarders.length forwarder.emit(tag, es) end
[Validate]
Generated with the Darkfish Rdoc Generator 2.