redis.clients.jedis

Class JedisClusterConnectionHandler

java.lang.Object

redis.clients.jedis.JedisClusterConnectionHandler

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Direct Known Subclasses:

JedisSlotBasedConnectionHandler

public abstract class JedisClusterConnectionHandler
extends java.lang.Object
implements java.io.Closeable

Field Summary

Fields

Modifier and Type	Field and Description
protected JedisClusterInfoCache	cache

Constructor Summary

Constructors

Constructor and Description
JedisClusterConnectionHandler(java.util.Set<HostAndPort> nodes, org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, int connectionTimeout, int soTimeout, java.lang.String password)

Method Summary

Modifier and Type	Method and Description
void	close()
(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, java.lang.String password)
void	renewSlotCache()
void	renewSlotCache(Jedis jedis)

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

Constructor Detail

JedisClusterConnectionHandler

public JedisClusterConnectionHandler(java.util.Set<HostAndPort> nodes,
                                     org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                                     int connectionTimeout,
                                     int soTimeout,
                                     java.lang.String password)

Method Detail

getConnection

abstract Jedis getConnection()

getConnectionFromSlot

abstract Jedis getConnectionFromSlot(int slot)

getConnectionFromNode

public Jedis getConnectionFromNode(HostAndPort node)

getNodes

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

initializeSlotsCache

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

renewSlotCache

public void renewSlotCache()

renewSlotCache

public void renewSlotCache(Jedis jedis)

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable