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 |