class Fluent::Plugin::RewriteFilter

Attributes

rewrite_rule[R]

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/filter_rewrite.rb, line 7
def configure(conf)
  require 'fluent/plugin/rewrite_rule'

  super

  @rewrite_rule = Fluent::RewriteRule.new(self, conf)
end
filter_stream(tag, es) click to toggle source
# File lib/fluent/plugin/filter_rewrite.rb, line 15
def filter_stream(tag, es)
  new_es = Fluent::MultiEventStream.new

  es.each do |time, record|
    record = @rewrite_rule.rewrite(record)
    new_es.add(time, record) if record
  end

  new_es
end