Class Mongo::PoolManager
In: lib/mongo/util/pool_manager.rb
Parent: Object

Methods

close   connect   healthy?   inspect   new  

Attributes

arbiters  [R] 
connection  [R] 
hosts  [R] 
max_bson_size  [R] 
members  [R] 
nodes  [R] 
primary  [R] 
primary_pool  [R] 
read_pool  [R] 
secondaries  [R] 
secondary_pools  [R] 
seeds  [R] 
tags_to_pools  [R] 

Public Class methods

[Source]

# File lib/mongo/util/pool_manager.rb, line 8
    def initialize(connection, seeds)
      @connection = connection
      @seeds = seeds
      @refresh_node = nil
      @previously_connected = false
    end

Public Instance methods

[Source]

# File lib/mongo/util/pool_manager.rb, line 41
    def close
      begin
        if @primary_pool
          @primary_pool.close
        end

        if @secondary_pools
          @secondary_pools.each do |pool|
            pool.close
          end
        end

        if @members
          @members.each do |member|
            member.close
          end
        end

        rescue ConnectionFailure
      end
    end

[Source]

# File lib/mongo/util/pool_manager.rb, line 19
    def connect
      if @previously_connected
        close
      end

      initialize_data
      members = connect_to_members
      initialize_pools(members)
      update_seed_list(members)

      @members = members
      @previously_connected = true
    end

[Source]

# File lib/mongo/util/pool_manager.rb, line 33
    def healthy?
      if !@refresh_node || !refresh_node.set_config
        return false
      end

      #if refresh_node.node_list
    end

[Source]

# File lib/mongo/util/pool_manager.rb, line 15
    def inspect
      "<Mongo::PoolManager:0x#{self.object_id.to_s(16)} @seeds=#{@seeds}>"
    end

[Validate]