class Fluent::Plugin::SystemdEntryFilter

Fluentd systemd/journal filter plugin

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# 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) click to toggle source
# File lib/fluent/plugin/filter_systemd_entry.rb, line 37
def filter(_tag, _time, entry)
  @mutator.run(entry)
end