Package redis.clients.jedis.providers

Class SentineledConnectionProvider

java.lang.Object

redis.clients.jedis.providers.SentineledConnectionProvider

All Implemented Interfaces:

AutoCloseable, ConnectionProvider

public class SentineledConnectionProvider
extends Object
implements ConnectionProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	SentineledConnectionProvider.SentinelListener

Field Summary

Fields

Modifier and Type	Field	Description
private HostAndPort	currentMaster
protected static final long	DEFAULT_SUBSCRIBE_RETRY_WAIT_TIME_MILLIS
private final Object	initPoolLock
private static final org.slf4j.Logger	LOG
private final JedisClientConfig	masterClientConfig
private final String	masterName
private final org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection>	masterPoolConfig
private ConnectionPool	pool
private final JedisClientConfig	sentinelClientConfig
protected final Collection<SentineledConnectionProvider.SentinelListener>	sentinelListeners
private final long	subscribeRetryWaitTimeMillis

Constructor Summary

Constructors

Constructor	Description
SentineledConnectionProvider(String masterName, JedisClientConfig masterClientConfig, Set<HostAndPort> sentinels, JedisClientConfig sentinelClientConfig)
SentineledConnectionProvider(String masterName, JedisClientConfig masterClientConfig, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, Set<HostAndPort> sentinels, JedisClientConfig sentinelClientConfig)
SentineledConnectionProvider(String masterName, JedisClientConfig masterClientConfig, org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig, Set<HostAndPort> sentinels, JedisClientConfig sentinelClientConfig, long subscribeRetryWaitTimeMillis)

Method Summary

Modifier and Type	Method	Description
void	close()
Connection	getConnection()
Connection	getConnection(CommandArguments args)
HostAndPort	getCurrentMaster()
private void	initMaster(HostAndPort master)
private HostAndPort	initSentinels(Set<HostAndPort> sentinels)
private static HostAndPort	toHostAndPort(String hostStr, String portStr)
private static HostAndPort	toHostAndPort(List<String> masterAddr)	Must be of size 2.

Methods inherited from class java.lang.Object

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

Methods inherited from interface redis.clients.jedis.providers.ConnectionProvider

getConnectionMap

Field Details

LOG

private static final org.slf4j.Logger LOG

DEFAULT_SUBSCRIBE_RETRY_WAIT_TIME_MILLIS

protected static final long DEFAULT_SUBSCRIBE_RETRY_WAIT_TIME_MILLIS

See Also:

• Constant Field Values

currentMaster

private volatile HostAndPort currentMaster

pool

private volatile ConnectionPool pool

masterName

private final String masterName

masterClientConfig

private final JedisClientConfig masterClientConfig

masterPoolConfig

private final org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> masterPoolConfig

sentinelListeners

protected final Collection<SentineledConnectionProvider.SentinelListener> sentinelListeners

sentinelClientConfig

private final JedisClientConfig sentinelClientConfig

subscribeRetryWaitTimeMillis

private final long subscribeRetryWaitTimeMillis

initPoolLock

private final Object initPoolLock

Constructor Details

SentineledConnectionProvider

public SentineledConnectionProvider(String masterName,
 JedisClientConfig masterClientConfig,
 Set<HostAndPort> sentinels,
 JedisClientConfig sentinelClientConfig)

SentineledConnectionProvider

public SentineledConnectionProvider(String masterName,
 JedisClientConfig masterClientConfig,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
 Set<HostAndPort> sentinels,
 JedisClientConfig sentinelClientConfig)

SentineledConnectionProvider

public SentineledConnectionProvider(String masterName,
 JedisClientConfig masterClientConfig,
 org.apache.commons.pool2.impl.GenericObjectPoolConfig<Connection> poolConfig,
 Set<HostAndPort> sentinels,
 JedisClientConfig sentinelClientConfig,
 long subscribeRetryWaitTimeMillis)

Method Details

getConnection

public Connection getConnection()

Specified by:

getConnection in interface ConnectionProvider

getConnection

public Connection getConnection(CommandArguments args)

Specified by:

getConnection in interface ConnectionProvider

close

public void close()

Specified by:

close in interface AutoCloseable

getCurrentMaster

public HostAndPort getCurrentMaster()

initMaster

private void initMaster(HostAndPort master)

initSentinels

private HostAndPort initSentinels(Set<HostAndPort> sentinels)

toHostAndPort

private static HostAndPort toHostAndPort(List<String> masterAddr)

Must be of size 2.

toHostAndPort

private static HostAndPort toHostAndPort(String hostStr,
 String portStr)