redis.clients.jedis

Class JedisClusterConnectionHandler

java.lang.Object

redis.clients.jedis.JedisClusterConnectionHandler

Direct Known Subclasses:

JedisSlotBasedConnectionHandler

public abstract class JedisClusterConnectionHandler
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected JedisClusterInfoCache	cache
private int	timeout

Constructor Summary

Constructors

Constructor and Description
JedisClusterConnectionHandler(java.util.Set<HostAndPort> nodes, org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, int timeout)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

cache

protected final JedisClusterInfoCache cache

timeout

private int timeout

Constructor Detail

JedisClusterConnectionHandler

public JedisClusterConnectionHandler(java.util.Set<HostAndPort> nodes,
                                     org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                                     int timeout)

Method Detail

getConnection

abstract Jedis getConnection()

returnConnection

public void returnConnection(Jedis connection)

returnBrokenConnection

public void returnBrokenConnection(Jedis connection)

getConnectionFromSlot

abstract Jedis getConnectionFromSlot(int slot)

getConnectionFromNode

public Jedis getConnectionFromNode(HostAndPort node)

getNodes

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

assignSlotToNode

public void assignSlotToNode(int slot,
                             HostAndPort targetNode)

initializeSlotsCache

private void initializeSlotsCache(java.util.Set<HostAndPort> startNodes,
                                  org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig)

renewSlotCache

public void renewSlotCache()