class Fluent::AddOutput
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_add.rb, line 15 def initialize super end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_add.rb, line 19 def configure(conf) super @tag_prefix = "#{@add_tag_prefix}." @add_hash = Hash.new @tag_proc = if @tag_prefix Proc.new {|tag| "#{@tag_prefix}#{tag}" } else Proc.new {|tag| tag } end conf.elements.select {|element| element.name == 'pair' }.each do |pair| pair.each do | k,v| pair.has_key?(k) # suppress warnings about unused configuration @add_hash[k] = v end end end
emit(tag, es, chain)
click to toggle source
# File lib/fluent/plugin/out_add.rb, line 41 def emit(tag, es, chain) emit_tag = @tag_proc.call(tag) es.each do |time,record| @add_hash.each do |k,v| record[k] = v end if @uuid record[@uuid_key] = SecureRandom.uuid.upcase end router.emit(emit_tag, time, record) end chain.next end