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