Package redis.clients.jedis.providers

Class ShardedConnectionProvider

java.lang.Object

redis.clients.jedis.providers.ShardedConnectionProvider

All Implemented Interfaces:

AutoCloseable, ConnectionProvider

public class ShardedConnectionProvider
extends Object
implements ConnectionProvider

Field Summary

Fields

Modifier and Type	Field	Description
private final Hashing	algo
private final JedisClientConfig	clientConfig
private final TreeMap<Long,HostAndPort>	nodes
private final org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection>	poolConfig
private final Map<String,ConnectionPool>	resources

Constructor Summary

Constructors

Constructor	Description
ShardedConnectionProvider(List<HostAndPort> shards)
ShardedConnectionProvider(List<HostAndPort> shards, JedisClientConfig clientConfig)
ShardedConnectionProvider(List<HostAndPort> shards, JedisClientConfig clientConfig, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)
ShardedConnectionProvider(List<HostAndPort> shards, JedisClientConfig clientConfig, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, Hashing algo)
ShardedConnectionProvider(List<HostAndPort> shards, JedisClientConfig clientConfig, Hashing algo)

Method Summary

Modifier and Type	Method	Description
void	close()
Connection	getConnection()
Connection	getConnection(CommandArguments args)
Connection	getConnection(HostAndPort node)
Map<String,ConnectionPool>	getConnectionMap()
Hashing	getHashingAlgo()
HostAndPort	getNode(Long hash)
private HostAndPort	getNodeFromHash(Long hash)
private List<ConnectionPool>	getShuffledNodesPool()
private void	initialize(List<HostAndPort> shards)
private void	reset()
private ConnectionPool	setupNodeIfNotExist(HostAndPort node)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

nodes

private final TreeMap<Long,HostAndPort> nodes

resources

private final Map<String,ConnectionPool> resources

clientConfig

private final JedisClientConfig clientConfig

poolConfig

private final org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig

algo

private final Hashing algo

Constructor Details

ShardedConnectionProvider

public ShardedConnectionProvider(List<HostAndPort> shards)

ShardedConnectionProvider

public ShardedConnectionProvider(List<HostAndPort> shards,
 JedisClientConfig clientConfig)

ShardedConnectionProvider

public ShardedConnectionProvider(List<HostAndPort> shards,
 JedisClientConfig clientConfig,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)

ShardedConnectionProvider

public ShardedConnectionProvider(List<HostAndPort> shards,
 JedisClientConfig clientConfig,
 Hashing algo)

ShardedConnectionProvider

public ShardedConnectionProvider(List<HostAndPort> shards,
 JedisClientConfig clientConfig,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
 Hashing algo)

Method Details

initialize

private void initialize(List<HostAndPort> shards)

setupNodeIfNotExist

private ConnectionPool setupNodeIfNotExist(HostAndPort node)

getHashingAlgo

public Hashing getHashingAlgo()

reset

private void reset()

close

public void close()

Specified by:

close in interface AutoCloseable

getNode

public HostAndPort getNode(Long hash)

getConnection

public Connection getConnection(HostAndPort node)

getConnection

public Connection getConnection(CommandArguments args)

Specified by:

getConnection in interface ConnectionProvider

getShuffledNodesPool

private List<ConnectionPool> getShuffledNodesPool()

getConnection

public Connection getConnection()

Specified by:

getConnection in interface ConnectionProvider

getNodeFromHash

private HostAndPort getNodeFromHash(Long hash)

getConnectionMap

public Map<String,ConnectionPool> getConnectionMap()

Specified by:

getConnectionMap in interface ConnectionProvider