Parent

Mongo::PoolManager

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

new(connection, seeds) click to toggle 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

close() click to toggle 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
connect() click to toggle 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
healthy?() click to toggle 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
inspect() click to toggle 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]

Generated with the Darkfish Rdoc Generator 2.