Class: RedisRing::Client::ShardConnectionPool

Inherits:
Object
  • Object
show all
Defined in:
lib/redis_ring/client/shard_connection_pool.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(metadata, password, db) ⇒ ShardConnectionPool

Returns a new instance of ShardConnectionPool.



8
9
10
11
12
13
 
# File 'lib/redis_ring/client/shard_connection_pool.rb', line 8

def initialize(metadata, password, db)
  @metadata = metadata
  @password = password
  @db = db
  @connections = {}
end

Instance Attribute Details

#db ⇒ Object (readonly)

Returns the value of attribute db.



6
7
8
 
# File 'lib/redis_ring/client/shard_connection_pool.rb', line 6

def db
  @db
end

#metadata ⇒ Object (readonly)

Returns the value of attribute metadata.



6
7
8
 
# File 'lib/redis_ring/client/shard_connection_pool.rb', line 6

def metadata
  @metadata
end

#password ⇒ Object (readonly)

Returns the value of attribute password.



6
7
8
 
# File 'lib/redis_ring/client/shard_connection_pool.rb', line 6

def password
  @password
end

Instance Method Details

#connection(shard_number) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
 
# File 'lib/redis_ring/client/shard_connection_pool.rb', line 15

def connection(shard_number)
  connection, conn_id = @connections[shard_number]
  shard_metadata = metadata.shard(shard_number)
  unless conn_id == shard_metadata.to_sym
    connection = new_connection(shard_metadata.host, shard_metadata.port, db, password)
    conn_id = shard_metadata.to_sym
    @connections[shard_number] = [connection, conn_id]
  end
  connection
end