Class: Fluent::Plugin::SystemdEntryFilter

Inherits:
Filter
  • Object
show all
Defined in:
lib/fluent/plugin/filter_systemd_entry.rb

Overview

Fluentd systemd/journal filter plugin

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



31
32
33
34
35
 
# File 'lib/fluent/plugin/filter_systemd_entry.rb', line 31

def configure(conf)
  super
  @mutator = SystemdEntryMutator.new(**@config_root_section.to_h)
  @mutator.warnings.each { |warning| log.warn(warning) }
end

#filter(_tag, _time, entry) ⇒ Object 



37
38
39
 
# File 'lib/fluent/plugin/filter_systemd_entry.rb', line 37

def filter(_tag, _time, entry)
  @mutator.run(entry)
end