Parent

Methods

Class/Module Index [+]

Quicksearch

Fluent::DetachProcessManager::MultiForwarder

Public Class Methods

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

Public Instance Methods

emit(tag, es) click to toggle source
# 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.