Class: Fluent::Plugin::FilterListFilter

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

Instance Method Summary collapse

Methods included from BaseFilter

#should_filter?

Instance Method Details

#configure(conf) ⇒ Object 



22
23
24
25
26
 
# File 'lib/fluent/plugin/filter_filter_list.rb', line 22

def configure(conf)
  super
  patterns = @pattern_file_paths.flat_map { |p| File.readlines(p).map(&:chomp).reject(&:empty?) }
  @matcher = (@filter == 'IP') ? IPMatcher.new(patterns) : ACMatcher.new(patterns)
end

#filter(_tag, _time, record) ⇒ Object 



28
29
30
31
32
33
34
 
# File 'lib/fluent/plugin/filter_filter_list.rb', line 28

def filter(_tag, _time, record)
  target = record[@key_to_filter]

  return nil if should_filter?(target)

  record
end