Contents

require 'fluent/plugin/out_mongo'

module Fluent
  class MongoOutputTagCollection < MongoOutput
    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.16	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.15	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.14	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.13	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.12	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.11	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.10	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.9	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.8	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.7	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.6	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.5	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.4	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.3	lib/fluent/plugin/out_mongo_tag_collection.rb
fluent-plugin-mongo-0.7.2	lib/fluent/plugin/out_mongo_tag_collection.rb