class Fluent::DetachProcessManager::MultiForwarder

Public Class Methods

new(forwarders) click to toggle source
# File lib/fluent/process.rb, line 285
def initialize(forwarders)
  @forwarders = forwarders
  @rr = 1
end

Public Instance Methods

emit(tag, es) click to toggle source
# File lib/fluent/process.rb, line 290
def emit(tag, es)
  forwarder = @forwarders[@rr]
  @rr = (@rr + 1) % @forwarders.length
  forwarder.emit(tag, es)
end