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

9 entries across 9 versions & 1 rubygems

Version	Path
fluent-plugin-mongo-0.7.10	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.9	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.8	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.7	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.6	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.5	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.4	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.3	lib/fluent/plugin/mongo_util.rb
fluent-plugin-mongo-0.7.2	lib/fluent/plugin/mongo_util.rb