Class: Fluent::DetachProcessManager::MultiForwarder

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/process.rb

Instance Method Summary collapse

Constructor Details

#initialize(forwarders) ⇒ MultiForwarder

Returns a new instance of MultiForwarder.



280
281
282
283
 
# File 'lib/fluent/process.rb', line 280

def initialize(forwarders)
  @forwarders = forwarders
  @rr = 1
end

Instance Method Details

#emit(tag, es) ⇒ Object 



285
286
287
288
289
 
# File 'lib/fluent/process.rb', line 285

def emit(tag, es)
  forwarder = @forwarders[@rr]
  @rr = (@rr + 1) % @forwarders.length
  forwarder.emit(tag, es)
end