Class: Fluent::Plugin::FilterListFilter

Inherits:
Filter
  • Object
show all
Includes:
Matchers
Defined in:
lib/fluent/plugin/filter_filter_list.rb

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object



14
15
16
17
18
# File 'lib/fluent/plugin/filter_filter_list.rb', line 14

def configure(conf)
  super
  patterns = @patterns_file_path.empty? ? [] : File.readlines(@patterns_file_path).map(&:chomp).reject(&:empty?)
  @matcher = ACMatcher.new(patterns)
end

#filter(_tag, _time, record) ⇒ Object



20
21
22
23
24
# File 'lib/fluent/plugin/filter_filter_list.rb', line 20

def filter(_tag, _time, record)
  target = record[@key_to_filter]
  return nil if target && @matcher.matches?(target)
  record
end