public abstract class JedisClusterConnectionHandler
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected JedisClusterInfoCache |
cache |
private int |
timeout |
| Constructor and Description |
|---|
JedisClusterConnectionHandler(java.util.Set<HostAndPort> nodes,
org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
int timeout) |
| Modifier and Type | Method and Description |
|---|---|
void |
assignSlotToNode(int slot,
HostAndPort targetNode) |
(package private) abstract Jedis |
getConnection() |
Jedis |
getConnectionFromNode(HostAndPort node) |
(package private) abstract Jedis |
getConnectionFromSlot(int slot) |
java.util.Map<java.lang.String,JedisPool> |
getNodes() |
private void |
initializeSlotsCache(java.util.Set<HostAndPort> startNodes,
org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig) |
void |
renewSlotCache() |
void |
returnBrokenConnection(Jedis connection) |
void |
returnConnection(Jedis connection) |
protected final JedisClusterInfoCache cache
private int timeout
public JedisClusterConnectionHandler(java.util.Set<HostAndPort> nodes, org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, int timeout)
abstract Jedis getConnection()
public void returnConnection(Jedis connection)
public void returnBrokenConnection(Jedis connection)
abstract Jedis getConnectionFromSlot(int slot)
public Jedis getConnectionFromNode(HostAndPort node)
public java.util.Map<java.lang.String,JedisPool> getNodes()
public void assignSlotToNode(int slot,
HostAndPort targetNode)
private void initializeSlotsCache(java.util.Set<HostAndPort> startNodes, org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig)
public void renewSlotCache()