Contents

module Fluent


module MongoUtil
  def self.included(klass)
    klass.instance_eval {
      config_param :user, :string, :default => nil
      config_param :password, :string, :default => nil
    }
  end

  def authenticate(db)
    unless @user.nil? || @password.nil?
      begin
        db.authenticate(@user, @password)
      rescue Mongo::AuthenticationError => e
        $log.fatal e
        exit!
      end
    end

    db
  end
end


end

Version data entries

13 entries across 13 versions & 1 rubygems

Version	Path
fluent-plugin-mongo-0.7.1	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.0	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.13	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.12	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.11	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.10	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.9	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.8	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.7	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.6	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.5	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.4	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.6.3	lib/fluent/plugin/mongo_util.rb