class Fluent::AddFilter
Public Class Methods
new()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_add.rb, line 9 def initialize super end
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_add.rb, line 13 def configure(conf) super @add_hash = Hash.new 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
filter(tag, time, record)
click to toggle source
# File lib/fluent/plugin/filter_add.rb, line 28 def filter(tag, time, record) @add_hash.each do |k,v| record[k] = v end if @uuid record[@uuid_key] = SecureRandom.uuid.upcase end record end