Sha256: c639f45ea211c2a80f5f089355e2266f4c766b899c3b526e84bc7fd5f978bed5

Contents?: true

Size: 591 Bytes

Versions: 1

Compression:

Stored size: 591 Bytes

Contents

class Fluent::RewriteTagNameMixinOutput < Fluent::Output
  Fluent::Plugin.register_output('rewrite_tag_name_mixin', self)

  config_param :tag, :string, :default => nil

  include Fluent::HandleTagNameMixin
  include Fluent::Mixin::RewriteTagName

  def configure(conf)
    super
    
    if @tag.nil?
      raise Fluent::ConfigError, "'tag' parameter is required."
    end

  end

  def emit(tag, es, chain)
    es.each do |time, record|
      emit_tag = tag.dup
      filter_record(emit_tag, time, record)
      Fluent::Engine.emit(emit_tag, time, record)
    end
    chain.next
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
fluent-mixin-rewrite-tag-name-0.0.1 test/plugin.rb