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
static ClusterNodeInformationParser	nodeInfoParser
private java.util.Map<java.lang.String,JedisPool>	nodes
private org.apache.commons.pool2.impl.GenericObjectPoolConfig	poolConfig
private java.util.concurrent.locks.Lock	r
private java.util.concurrent.locks.ReentrantReadWriteLock	rwl
private java.util.Map<java.lang.Integer,JedisPool>	slots
private int	timeout
private java.util.concurrent.locks.Lock	w

Constructor Summary

Constructors

Constructor and Description
JedisClusterInfoCache(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, int timeout)

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)
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()
JedisPool	getSlotPool(int slot)
void	setNodeIfNotExist(HostAndPort node)

Methods inherited from class java.lang.Object

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

Field Detail

nodeInfoParser

public static final ClusterNodeInformationParser nodeInfoParser

nodes

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

slots

private 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

poolConfig

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

timeout

private int timeout

Constructor Detail

JedisClusterInfoCache

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

Method Detail

discoverClusterNodesAndSlots

public void discoverClusterNodesAndSlots(Jedis jedis)

discoverClusterSlots

public void discoverClusterSlots(Jedis jedis)

generateHostAndPort

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

setNodeIfNotExist

public void setNodeIfNotExist(HostAndPort node)

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()

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)