Class: Fluent::Plugin::FilterOutput

Inherits:
Output
  • Object
show all
Includes:
FilterUtil
Defined in:
lib/fluent/plugin/out_filter.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from FilterUtil

#passRules, #toMap

Instance Attribute Details

#allows ⇒ Object

Returns the value of attribute allows.



19
20
21
 
# File 'lib/fluent/plugin/out_filter.rb', line 19

def allows
  @allows
end

#denies ⇒ Object

Returns the value of attribute denies.



20
21
22
 
# File 'lib/fluent/plugin/out_filter.rb', line 20

def denies
  @denies
end

Instance Method Details

#configure(conf) ⇒ Object 



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

def configure(conf)
  super
  @allows = toMap(@allow, @delim)
  @denies = toMap(@deny, @delim)
end

#process(tag, es) ⇒ Object 



33
34
35
36
37
38
39
40
41
 
# File 'lib/fluent/plugin/out_filter.rb', line 33

def process(tag, es)
  if @add_prefix
    tag = @add_prefix + '.' + tag
  end
  es.each do |time, record|
    next unless passRules(record)
    router.emit(tag, time, record)
  end
end