Package redis.clients.jedis.providers

Class ClusterConnectionProvider

java.lang.Object

redis.clients.jedis.providers.ClusterConnectionProvider

All Implemented Interfaces:

AutoCloseable, ConnectionProvider

public class ClusterConnectionProvider
extends Object
implements ConnectionProvider

Field Summary

Fields

Modifier and Type	Field	Description
protected final JedisClusterInfoCache	cache
private static final String	INIT_NO_ERROR_PROPERTY

Constructor Summary

Constructors

Constructor	Description
ClusterConnectionProvider(Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig)
ClusterConnectionProvider(Set<HostAndPort> clusterNodes, JedisClientConfig clientConfig, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)

Method Summary

Modifier and Type	Method	Description
void	close()
Connection	getConnection()
Connection	getConnection(CommandArguments args)
Connection	getConnection(HostAndPort node)
Connection	getConnectionFromSlot(int slot)
Map<String,ConnectionPool>	getConnectionMap()
HostAndPort	getNode(int slot)
Map<String,ConnectionPool>	getNodes()
private void	initializeSlotsCache(Set<HostAndPort> startNodes, JedisClientConfig clientConfig)
void	renewSlotCache()
void	renewSlotCache(Connection jedis)

Methods inherited from class java.lang.Object

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

Field Details

INIT_NO_ERROR_PROPERTY

private static final String INIT_NO_ERROR_PROPERTY

See Also:

• Constant Field Values

cache

protected final JedisClusterInfoCache cache

Constructor Details

ClusterConnectionProvider

public ClusterConnectionProvider(Set<HostAndPort> clusterNodes,
 JedisClientConfig clientConfig)

ClusterConnectionProvider

public ClusterConnectionProvider(Set<HostAndPort> clusterNodes,
 JedisClientConfig clientConfig,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)

Method Details

initializeSlotsCache

private void initializeSlotsCache(Set<HostAndPort> startNodes,
 JedisClientConfig clientConfig)

close

public void close()

Specified by:

close in interface AutoCloseable

renewSlotCache

public void renewSlotCache()

renewSlotCache

public void renewSlotCache(Connection jedis)

getNodes

public Map<String,ConnectionPool> getNodes()

getNode

public HostAndPort getNode(int slot)

getConnection

public Connection getConnection(HostAndPort node)

getConnection

public Connection getConnection(CommandArguments args)

Specified by:

getConnection in interface ConnectionProvider

getConnection

public Connection getConnection()

Specified by:

getConnection in interface ConnectionProvider

getConnectionFromSlot

public Connection getConnectionFromSlot(int slot)

getConnectionMap

public Map<String,ConnectionPool> getConnectionMap()

Specified by:

getConnectionMap in interface ConnectionProvider