Contents

# frozen_string_literal: true
require "fluent/plugin/filter"
require "fluent/plugin/systemd/entry_mutator"

module Fluent
  module Plugin
    # Fluentd systemd/journal filter plugin
    class SystemdEntryFilter < Filter
      Fluent::Plugin.register_filter("systemd_entry", self)

      config_param :field_map, :hash, default: {}
      config_param :field_map_strict, :bool, default: false
      config_param :fields_strip_underscores, :bool, default: false
      config_param :fields_lowercase, :bool, default: false

      def configure(conf)
        super
        @mutator = SystemdEntryMutator.new(**@config_root_section.to_h)
        if @mutator.field_map_strict && @mutator.field_map.empty?
          log.warn("`field_map_strict` set to true with empty `field_map`, expect no fields")
        end
      end

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

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
fluent-plugin-systemd-0.3.1	lib/fluent/plugin/filter_systemd_entry.rb
fluent-plugin-systemd-0.3.0	lib/fluent/plugin/filter_systemd_entry.rb