Contents

module Fluent
class FilterFilter < Filter
  require 'fluent/plugin/filter_util'
  include FilterUtil

  Plugin.register_filter('filter', self)

  config_param :all, :string, :default => 'allow'
  config_param :allow, :string, :default => ''
  config_param :deny, :string, :default => ''

  attr_accessor :allows
  attr_accessor :denies

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

  def filter(tag, time, record)
    record if passRules(record)
  end
end

end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
fluent-plugin-filter-0.0.4	lib/fluent/plugin/filter_filter.rb