Package redis.clients.jedis

Class JedisClusterInfoCache

java.lang.Object

redis.clients.jedis.JedisClusterInfoCache

public class JedisClusterInfoCache
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final JedisClientConfig	clientConfig
private static final int	MASTER_NODE_INDEX
private final Map<String,ConnectionPool>	nodes
private final org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection>	poolConfig
private final Lock	r
private final Lock	rediscoverLock
private final ReentrantReadWriteLock	rwl
private final HostAndPort[]	slotNodes
private final ConnectionPool[]	slots
private final Set<HostAndPort>	startNodes
private final Lock	w

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	assignSlotsToNode(List<Integer> targetSlots, HostAndPort targetNode)
void	assignSlotToNode(int slot, HostAndPort targetNode)
void	discoverClusterNodesAndSlots(Connection jedis)
private void	discoverClusterSlots(Connection jedis)
private List<Object>	executeClusterSlots(Connection jedis)
private HostAndPort	generateHostAndPort(List<Object> hostInfos)
private List<Integer>	getAssignedSlotArray(List<Object> slotInfo)
ConnectionPool	getNode(String nodeKey)
ConnectionPool	getNode(HostAndPort node)
static String	getNodeKey(HostAndPort hnp)
Map<String,ConnectionPool>	getNodes()
List<ConnectionPool>	getShuffledNodesPool()
HostAndPort	getSlotNode(int slot)
ConnectionPool	getSlotPool(int slot)
void	renewClusterSlots(Connection jedis)
void	reset()	Clear discovered nodes collections and gently release allocated resources
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 Map<String,ConnectionPool> nodes

slots

private final ConnectionPool[] slots

slotNodes

private final HostAndPort[] slotNodes

rwl

private final ReentrantReadWriteLock rwl

r

private final Lock r

w

private final Lock w

rediscoverLock

private final Lock rediscoverLock

poolConfig

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

clientConfig

private final JedisClientConfig clientConfig

startNodes

private final Set<HostAndPort> startNodes

MASTER_NODE_INDEX

private static final int MASTER_NODE_INDEX

See Also:

• Constant Field Values

Constructor Details

JedisClusterInfoCache

@Deprecated
public JedisClusterInfoCache(JedisClientConfig clientConfig)

Deprecated.

JedisClusterInfoCache

@Deprecated
public JedisClusterInfoCache(JedisClientConfig clientConfig,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig)

Deprecated.

JedisClusterInfoCache

public JedisClusterInfoCache(JedisClientConfig clientConfig,
 Set<HostAndPort> startNodes)

JedisClusterInfoCache

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

Method Details

discoverClusterNodesAndSlots

public void discoverClusterNodesAndSlots(Connection jedis)

renewClusterSlots

public void renewClusterSlots(Connection jedis)

discoverClusterSlots

private void discoverClusterSlots(Connection jedis)

generateHostAndPort

private HostAndPort generateHostAndPort(List<Object> hostInfos)

setupNodeIfNotExist

public ConnectionPool setupNodeIfNotExist(HostAndPort node)

assignSlotToNode

public void assignSlotToNode(int slot,
 HostAndPort targetNode)

assignSlotsToNode

public void assignSlotsToNode(List<Integer> targetSlots,
 HostAndPort targetNode)

getNode

public ConnectionPool getNode(String nodeKey)

getNode

public ConnectionPool getNode(HostAndPort node)

getSlotPool

public ConnectionPool getSlotPool(int slot)

getSlotNode

public HostAndPort getSlotNode(int slot)

getNodes

public Map<String,ConnectionPool> getNodes()

getShuffledNodesPool

public List<ConnectionPool> getShuffledNodesPool()

reset

public void reset()

Clear discovered nodes collections and gently release allocated resources

getNodeKey

public static String getNodeKey(HostAndPort hnp)

executeClusterSlots

private List<Object> executeClusterSlots(Connection jedis)

getAssignedSlotArray

private List<Integer> getAssignedSlotArray(List<Object> slotInfo)