Contents

# frozen_string_literal: true

require_relative '../base.rb'

module Fusuma
  module Plugin
    # filter class
    module Filters
      # Filter record to keep
      class Filter < Base
        # Filter input event
        # @param event [Event]
        # @return [Event, nil]
        def filter(event)
          event.tap do |e|
            next if e.tag != source
            next if keep?(e.record)

            MultiLogger.debug(filtered: e)

            break nil
          end
        end

        # @abstract override `#keep?` to implement
        # @param record [String]
        # @return [True]  when keeping record
        # @return [False] when discarding record
        def keep?(record)
          true if record
        end

        # Set source for tag from config.yml.
        # DEFAULT_SOURCE is defined in each Filter plugins.
        def source
          @source ||= config_params(:source) || self.class.const_get('DEFAULT_SOURCE')
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fusuma-1.2.1	lib/fusuma/plugin/filters/filter.rb