Parent

Class/Module Index [+]

Quicksearch

Fluent::CopyOutput

Attributes

outputs[R]

Public Class Methods

new() click to toggle source
# File lib/fluent/plugin/out_copy.rb, line 24
def initialize
  @outputs = []
end

Public Instance Methods

configure(conf) click to toggle source
# File lib/fluent/plugin/out_copy.rb, line 30
def configure(conf)
  conf.elements.select {|e|
    e.name == 'store'
  }.each {|e|
    type = e['type']
    unless type
      raise ConfigError, "Missing 'type' parameter on <store> directive"
    end
    $log.debug "adding store type=#{type.dump}"

    output = Plugin.new_output(type)
    output.configure(e)
    @outputs << output
  }
end
emit(tag, es, chain) click to toggle source
# File lib/fluent/plugin/out_copy.rb, line 58
def emit(tag, es, chain)
  unless es.repeatable?
    m = MultiEventStream.new
    es.each {|time,record|
      m.add(time, record)
    }
    es = m
  end
  chain = OutputChain.new(@outputs, tag, es, chain)
  chain.next
end
shutdown() click to toggle source
# File lib/fluent/plugin/out_copy.rb, line 52
def shutdown
  @outputs.each {|o|
    o.shutdown
  }
end
start() click to toggle source
# File lib/fluent/plugin/out_copy.rb, line 46
def start
  @outputs.each {|o|
    o.start
  }
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.