class Fluent::AnonymizerOutput

Public Class Methods

new() click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_anonymizer.rb, line 33
def initialize
  require 'fluent/plugin/anonymizer'
  super
end

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/out_anonymizer.rb, line 38
def configure(conf)
  log.warn "out_anonymizer is now deprecated. It will be removed in a future release. Please consider to use filter_anonymizer."
  super
  @anonymizer = Fluent::Anonymizer.new(self, conf)
end
emit(tag, es, chain) click to toggle source
# File lib/fluent/plugin/out_anonymizer.rb, line 44
def emit(tag, es, chain)
  es.each do |time, record|
    record = @anonymizer.anonymize(record)
    emit_tag = tag.dup
    filter_record(emit_tag, time, record)
    router.emit(emit_tag, time, record)
  end
  chain.next
end