redis.clients.jedis

Class JedisClusterInfoCache

java.lang.Object

redis.clients.jedis.JedisClusterInfoCache

public class JedisClusterInfoCache
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private int	connectionTimeout
private static int	MASTER_NODE_INDEX
private java.util.Map<java.lang.String,JedisPool>	nodes
private java.lang.String	password
private org.apache.commons.pool2.impl.GenericObjectPoolConfig	poolConfig
private java.util.concurrent.locks.Lock	r
private boolean	rediscovering
private java.util.concurrent.locks.ReentrantReadWriteLock	rwl
private java.util.Map<java.lang.Integer,JedisPool>	slots
private int	soTimeout
private java.util.concurrent.locks.Lock	w

Constructor Summary

Constructors

Constructor and Description
JedisClusterInfoCache(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, int timeout)
JedisClusterInfoCache(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, int connectionTimeout, int soTimeout, java.lang.String password)

Method Summary

Modifier and Type	Method and Description
void	assignSlotsToNode(java.util.List<java.lang.Integer> targetSlots, HostAndPort targetNode)
void	assignSlotToNode(int slot, HostAndPort targetNode)
void	discoverClusterNodesAndSlots(Jedis jedis)
private void	discoverClusterSlots(Jedis jedis)
private HostAndPort	generateHostAndPort(java.util.List<java.lang.Object> hostInfos)
private java.util.List<java.lang.Integer>	getAssignedSlotArray(java.util.List<java.lang.Object> slotInfo)
JedisPool	getNode(java.lang.String nodeKey)
static java.lang.String	getNodeKey(Client client)
static java.lang.String	getNodeKey(HostAndPort hnp)
static java.lang.String	getNodeKey(Jedis jedis)
java.util.Map<java.lang.String,JedisPool>	getNodes()
java.util.List<JedisPool>	getShuffledNodesPool()
JedisPool	getSlotPool(int slot)
void	renewClusterSlots(Jedis jedis)
void	reset() Clear discovered nodes collections and gently release allocated resources
JedisPool	setupNodeIfNotExist(HostAndPort node)
JedisPool	setupNodeIfNotExist(HostAndPort node, boolean ssl)
JedisPool	setupNodeIfNotExist(HostAndPort node, boolean ssl, javax.net.ssl.SSLSocketFactory sslSocketFactory, javax.net.ssl.SSLParameters sslParameters, javax.net.ssl.HostnameVerifier hostnameVerifier)

Methods inherited from class java.lang.Object

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

Field Detail

nodes

private final java.util.Map<java.lang.String,JedisPool> nodes

slots

private final java.util.Map<java.lang.Integer,JedisPool> slots

rwl

private final java.util.concurrent.locks.ReentrantReadWriteLock rwl

r

private final java.util.concurrent.locks.Lock r

w

private final java.util.concurrent.locks.Lock w

rediscovering

private volatile boolean rediscovering

poolConfig

private final org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig

connectionTimeout

private int connectionTimeout

soTimeout

private int soTimeout

password

private java.lang.String password

MASTER_NODE_INDEX

private static final int MASTER_NODE_INDEX

See Also:

Constant Field Values

Constructor Detail

JedisClusterInfoCache

public JedisClusterInfoCache(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                             int timeout)

JedisClusterInfoCache

public JedisClusterInfoCache(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                             int connectionTimeout,
                             int soTimeout,
                             java.lang.String password)

Method Detail

discoverClusterNodesAndSlots

public void discoverClusterNodesAndSlots(Jedis jedis)

renewClusterSlots

public void renewClusterSlots(Jedis jedis)

discoverClusterSlots

private void discoverClusterSlots(Jedis jedis)

generateHostAndPort

private HostAndPort generateHostAndPort(java.util.List<java.lang.Object> hostInfos)

setupNodeIfNotExist

public JedisPool setupNodeIfNotExist(HostAndPort node)

setupNodeIfNotExist

public JedisPool setupNodeIfNotExist(HostAndPort node,
                                     boolean ssl)

setupNodeIfNotExist

public JedisPool setupNodeIfNotExist(HostAndPort node,
                                     boolean ssl,
                                     javax.net.ssl.SSLSocketFactory sslSocketFactory,
                                     javax.net.ssl.SSLParameters sslParameters,
                                     javax.net.ssl.HostnameVerifier hostnameVerifier)

assignSlotToNode

public void assignSlotToNode(int slot,
                             HostAndPort targetNode)

assignSlotsToNode

public void assignSlotsToNode(java.util.List<java.lang.Integer> targetSlots,
                              HostAndPort targetNode)

getNode

public JedisPool getNode(java.lang.String nodeKey)

getSlotPool

public JedisPool getSlotPool(int slot)

getNodes

public java.util.Map<java.lang.String,JedisPool> getNodes()

getShuffledNodesPool

public java.util.List<JedisPool> getShuffledNodesPool()

reset

public void reset()

Clear discovered nodes collections and gently release allocated resources

getNodeKey

public static java.lang.String getNodeKey(HostAndPort hnp)

getNodeKey

public static java.lang.String getNodeKey(Client client)

getNodeKey

public static java.lang.String getNodeKey(Jedis jedis)

getAssignedSlotArray

private java.util.List<java.lang.Integer> getAssignedSlotArray(java.util.List<java.lang.Object> slotInfo)