Contents

require 'fluent/plugin/out_mongo'

module Fluent


class MongoOutputTagCollection < MongoOutput
  Fluent::Plugin.register_output('mongo_tag_collection', self)

  config_param :collection, :string, :default => 'untagged'

  def configure(conf)
    super

    @tag_mapped = true
    if remove_prefix_collection = conf['remove_prefix_collection']
      @remove_tag_prefix = Regexp.new('^' + Regexp.escape(remove_prefix_collection))
    end

    $log.warn "'mongo_tag_collection' deprecated. Please use 'mongo' type with 'tag_mapped' parameter"
  end
end


end

Version data entries

15 entries across 15 versions & 1 rubygems

Version	Path
fluent-plugin-mongo-0.7.0	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.13	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.12	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.11	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.10	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.9	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.8	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.7	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.6	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.5	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.4	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.3	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.2	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.1	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.6.0	lib/fluent/plugin/out_mongo_tag_collection.rb