class Fluent::HasKeysFilter
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_has_keys.rb, line 7 def configure(conf) super @essential_keys = @keys ? @keys.split(",").map(&:strip) : nil end
filter_stream(tag, es)
click to toggle source
# File lib/fluent/plugin/filter_has_keys.rb, line 20 def filter_stream(tag, es) new_es = MultiEventStream.new es.each do |time, record| if @essential_keys.nil? or @essential_keys.all? {|k| record.has_key?(k) } new_es.add(time, record) end end return new_es end
shutdown()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_has_keys.rb, line 16 def shutdown super end
start()
click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_has_keys.rb, line 12 def start super end