Module: Moped::Connection::Manager

Extended by:
Manager
Included in:
Manager
Defined in:
lib/moped/connection/manager.rb

Overview

This class contains behaviour of connection pools for specific addresses.

Since:

  • 2.0.0

Constant Summary collapse

MUTEX =

Used for synchronization of pools access.

Since:

  • 2.0.0

Mutex.new
POOL_SIZE =

The default max size for the connection pool.

Since:

  • 2.0.0

5
TIMEOUT =

The default timeout for getting connections from the queue.

Since:

  • 2.0.0

0.5

Instance Method Summary collapse

Instance Method Details

#pool(node) ⇒ Pool

Get a connection pool for the provided node.

Examples:

Get a connection pool for the node.

Manager.pool(node)

Parameters:

  • The (Node) —

    node.

Returns:

  • (Pool) —

    The connection pool for the Node.

Since:

  • 2.0.0



32
33
34
35
36
 
# File 'lib/moped/connection/manager.rb', line 32

def pool(node)
  MUTEX.synchronize do
    pools[node.address.resolved] ||= create_pool(node)
  end
end