Package redis.clients.jedis

Class JedisSentinelPool

java.lang.Object

org.apache.commons.pool2.BaseObject

org.apache.commons.pool2.impl.BaseGenericObjectPool<Jedis>

org.apache.commons.pool2.impl.GenericObjectPool<Jedis>

redis.clients.jedis.util.Pool<Jedis>

redis.clients.jedis.JedisSentinelPool

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.commons.pool2.impl.GenericObjectPoolMXBean, org.apache.commons.pool2.ObjectPool<Jedis>, org.apache.commons.pool2.UsageTracking<Jedis>

public class JedisSentinelPool
extends Pool<Jedis>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	JedisSentinelPool.MasterListener

Field Summary

Fields

Modifier and Type	Field	Description
private HostAndPort	currentHostMaster
private final JedisFactory	factory
private final Object	initPoolLock
private static final org.slf4j.Logger	LOG
protected final Collection<JedisSentinelPool.MasterListener>	masterListeners
private final JedisClientConfig	sentinelClientConfig

Fields inherited from class org.apache.commons.pool2.impl.BaseGenericObjectPool

abandonedConfig, MEAN_TIMING_STATS_CACHE_SIZE

Constructor Summary

Constructors

Constructor	Description
JedisSentinelPool(String masterName, Set<String> sentinels)
JedisSentinelPool(String masterName, Set<String> sentinels, String password)
JedisSentinelPool(String masterName, Set<String> sentinels, String password, String sentinelPassword)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int timeout)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, int infiniteSoTimeout, String user, String password, int database, String clientName)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, int infiniteSoTimeout, String user, String password, int database, String clientName, int sentinelConnectionTimeout, int sentinelSoTimeout, String sentinelUser, String sentinelPassword, String sentinelClientName)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, String password, int database)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, String password, int database, String clientName)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, String password, int database, String clientName, int sentinelConnectionTimeout, int sentinelSoTimeout, String sentinelPassword, String sentinelClientName)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, String user, String password, int database)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, String user, String password, int database, String clientName)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, String user, String password, int database, String clientName, int sentinelConnectionTimeout, int sentinelSoTimeout, String sentinelUser, String sentinelPassword, String sentinelClientName)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int timeout, String password)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int timeout, String password, int database)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int timeout, String password, int database, String clientName)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int timeout, String user, String password, int database)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, int timeout, String user, String password, int database, String clientName)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, String password)
JedisSentinelPool(String masterName, Set<String> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, JedisFactory factory)
JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, JedisClientConfig masteClientConfig, JedisClientConfig sentinelClientConfig)
JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig, JedisFactory factory, JedisClientConfig sentinelClientConfig)
JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, JedisClientConfig masteClientConfig, JedisClientConfig sentinelClientConfig)
JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, JedisFactory factory, JedisClientConfig sentinelClientConfig)

Method Summary

Modifier and Type	Method	Description
void	destroy()
HostAndPort	getCurrentHostMaster()
Jedis	getResource()
private void	initMaster(HostAndPort master)
private HostAndPort	initSentinels(Set<HostAndPort> sentinels, String masterName)
private static Set<HostAndPort>	parseHostAndPorts(Set<String> strings)
void	returnResource(Jedis resource)
private HostAndPort	toHostAndPort(List<String> getMasterAddrByNameResult)

Methods inherited from class redis.clients.jedis.util.Pool

addObjects, close, returnBrokenResource

Methods inherited from class org.apache.commons.pool2.impl.GenericObjectPool

addObject, borrowObject, borrowObject, borrowObject, clear, evict, getFactory, getFactoryType, getMaxIdle, getMinIdle, getNumActive, getNumIdle, getNumWaiters, invalidateObject, invalidateObject, listAllObjects, preparePool, returnObject, setConfig, setMaxIdle, setMinIdle, toStringAppendFields, use

Methods inherited from class org.apache.commons.pool2.impl.BaseGenericObjectPool

getBlockWhenExhausted, getBorrowedCount, getCollectDetailedStatistics, getCreatedCount, getCreationStackTrace, getDestroyedByBorrowValidationCount, getDestroyedByEvictorCount, getDestroyedCount, getDurationBetweenEvictionRuns, getEvictionPolicy, getEvictionPolicyClassName, getEvictorShutdownTimeout, getEvictorShutdownTimeoutDuration, getEvictorShutdownTimeoutMillis, getFairness, getJmxName, getLifo, getLogAbandoned, getMaxBorrowWaitDuration, getMaxBorrowWaitTimeMillis, getMaxTotal, getMaxWaitDuration, getMaxWaitMillis, getMeanActiveDuration, getMeanActiveTimeMillis, getMeanBorrowWaitDuration, getMeanBorrowWaitTimeMillis, getMeanIdleDuration, getMeanIdleTimeMillis, getMessageStatistics, getMinEvictableIdleDuration, getMinEvictableIdleTime, getMinEvictableIdleTimeMillis, getNumTestsPerEvictionRun, getRemoveAbandonedOnBorrow, getRemoveAbandonedOnMaintenance, getRemoveAbandonedTimeout, getRemoveAbandonedTimeoutDuration, getReturnedCount, getSoftMinEvictableIdleDuration, getSoftMinEvictableIdleTime, getSoftMinEvictableIdleTimeMillis, getSwallowedExceptionListener, getTestOnBorrow, getTestOnCreate, getTestOnReturn, getTestWhileIdle, getTimeBetweenEvictionRuns, getTimeBetweenEvictionRunsMillis, isAbandonedConfig, isClosed, markReturningState, setAbandonedConfig, setBlockWhenExhausted, setCollectDetailedStatistics, setConfig, setDurationBetweenEvictionRuns, setEvictionPolicy, setEvictionPolicyClassName, setEvictionPolicyClassName, setEvictorShutdownTimeout, setEvictorShutdownTimeoutMillis, setLifo, setMaxTotal, setMaxWait, setMaxWaitMillis, setMessagesStatistics, setMinEvictableIdle, setMinEvictableIdleDuration, setMinEvictableIdleTime, setMinEvictableIdleTimeMillis, setNumTestsPerEvictionRun, setSoftMinEvictableIdle, setSoftMinEvictableIdleDuration, setSoftMinEvictableIdleTime, setSoftMinEvictableIdleTimeMillis, setSwallowedExceptionListener, setTestOnBorrow, setTestOnCreate, setTestOnReturn, setTestWhileIdle, setTimeBetweenEvictionRuns, setTimeBetweenEvictionRunsMillis

Methods inherited from class org.apache.commons.pool2.BaseObject

toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.commons.pool2.impl.GenericObjectPoolMXBean

getBlockWhenExhausted, getBorrowedCount, getCreatedCount, getCreationStackTrace, getDestroyedByBorrowValidationCount, getDestroyedByEvictorCount, getDestroyedCount, getFairness, getLifo, getLogAbandoned, getMaxBorrowWaitTimeMillis, getMaxTotal, getMaxWaitMillis, getMeanActiveTimeMillis, getMeanBorrowWaitTimeMillis, getMeanIdleTimeMillis, getMinEvictableIdleTimeMillis, getNumTestsPerEvictionRun, getRemoveAbandonedOnBorrow, getRemoveAbandonedOnMaintenance, getRemoveAbandonedTimeout, getReturnedCount, getTestOnBorrow, getTestOnCreate, getTestOnReturn, getTestWhileIdle, getTimeBetweenEvictionRunsMillis, isAbandonedConfig, isClosed

Field Details

LOG

private static final org.slf4j.Logger LOG

factory

private final JedisFactory factory

sentinelClientConfig

private final JedisClientConfig sentinelClientConfig

masterListeners

protected final Collection<JedisSentinelPool.MasterListener> masterListeners

currentHostMaster

private volatile HostAndPort currentHostMaster

initPoolLock

private final Object initPoolLock

Constructor Details

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<HostAndPort> sentinels,
 JedisClientConfig masteClientConfig,
 JedisClientConfig sentinelClientConfig)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 String password)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 String password,
 String sentinelPassword)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int timeout,
 String password)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int timeout)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 String password)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int timeout,
 String password,
 int database)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int timeout,
 String user,
 String password,
 int database)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int timeout,
 String password,
 int database,
 String clientName)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int timeout,
 String user,
 String password,
 int database,
 String clientName)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int connectionTimeout,
 int soTimeout,
 String password,
 int database)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int connectionTimeout,
 int soTimeout,
 String user,
 String password,
 int database)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int connectionTimeout,
 int soTimeout,
 String password,
 int database,
 String clientName)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int connectionTimeout,
 int soTimeout,
 String user,
 String password,
 int database,
 String clientName)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int connectionTimeout,
 int soTimeout,
 int infiniteSoTimeout,
 String user,
 String password,
 int database,
 String clientName)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int connectionTimeout,
 int soTimeout,
 String password,
 int database,
 String clientName,
 int sentinelConnectionTimeout,
 int sentinelSoTimeout,
 String sentinelPassword,
 String sentinelClientName)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int connectionTimeout,
 int soTimeout,
 String user,
 String password,
 int database,
 String clientName,
 int sentinelConnectionTimeout,
 int sentinelSoTimeout,
 String sentinelUser,
 String sentinelPassword,
 String sentinelClientName)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 int connectionTimeout,
 int soTimeout,
 int infiniteSoTimeout,
 String user,
 String password,
 int database,
 String clientName,
 int sentinelConnectionTimeout,
 int sentinelSoTimeout,
 String sentinelUser,
 String sentinelPassword,
 String sentinelClientName)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<String> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 JedisFactory factory)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<HostAndPort> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 JedisClientConfig masteClientConfig,
 JedisClientConfig sentinelClientConfig)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<HostAndPort> sentinels,
 JedisFactory factory,
 JedisClientConfig sentinelClientConfig)

JedisSentinelPool

public JedisSentinelPool(String masterName,
 Set<HostAndPort> sentinels,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Jedis> poolConfig,
 JedisFactory factory,
 JedisClientConfig sentinelClientConfig)

Method Details

parseHostAndPorts

private static Set<HostAndPort> parseHostAndPorts(Set<String> strings)

destroy

public void destroy()

Overrides:

destroy in class Pool<Jedis>

getCurrentHostMaster

public HostAndPort getCurrentHostMaster()

initMaster

private void initMaster(HostAndPort master)

initSentinels

private HostAndPort initSentinels(Set<HostAndPort> sentinels,
 String masterName)

toHostAndPort

private HostAndPort toHostAndPort(List<String> getMasterAddrByNameResult)

getResource

public Jedis getResource()

Overrides:

getResource in class Pool<Jedis>

returnResource

public void returnResource(Jedis resource)

Overrides:

returnResource in class Pool<Jedis>