class Fluent::DetachProcessManager::MultiForwarder
Public Class Methods
new(forwarders)
click to toggle source
# File lib/fluent/process.rb, line 264 def initialize(forwarders) @forwarders = forwarders @rr = 1 end
Public Instance Methods
emit(tag, es)
click to toggle source
# File lib/fluent/process.rb, line 269 def emit(tag, es) forwarder = @forwarders[@rr] @rr = (@rr + 1) % @forwarders.length forwarder.emit(tag, es) end