Contents

module Fluent
  class Filter
    include Configurable
    include PluginId
    include PluginLoggerMixin

    def initialize
      super
    end

    def configure(conf)
      super
    end

    def start
    end

    def shutdown
    end

    def filter(tag, time, record)
    end

    def filter_stream(tag, es)
      new_es = MultiEventStream.new
      es.each { |time, record|
        new_es.add(time, filter(tag, time, record))
      }
      new_es
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
fluentd-0.12.0.pre.2	lib/fluent/filter.rb
fluentd-0.12.0.pre.1	lib/fluent/filter.rb