org.redisson.cluster

Class ClusterConnectionManager

java.lang.Object

org.redisson.connection.MasterSlaveConnectionManager

org.redisson.cluster.ClusterConnectionManager

All Implemented Interfaces:

ConnectionManager

public class ClusterConnectionManager
extends MasterSlaveConnectionManager

Author:

Nikita Koksharov

Field Summary

Fields inherited from class org.redisson.connection.MasterSlaveConnectionManager

codec, config, dnsMonitor, group, id, MAX_SLOT, resolverGroup, singleSlotRange, socketChannelClass

Constructor Summary

Constructors

Constructor and Description
ClusterConnectionManager(ClusterServersConfig cfg, Config config, UUID id)

Method Summary

Modifier and Type	Method and Description
URI	applyNatMap(URI address)
int	calcSlot(byte[] key)
int	calcSlot(String key)
protected RedisClientConfig	createRedisConfig(NodeType type, URI address, int timeout, int commandTimeout, String sslHostname)
String	getConfigEndpointHostName()
URI	getLastClusterNode()
boolean	isClusterMode()
void	shutdown()

Methods inherited from class org.redisson.connection.MasterSlaveConnectionManager

addEntry, changeMaster, closeNodeConnection, closeNodeConnections, connectionReadOp, connectionWriteOp, connectToNode, create, createClient, createClient, createClient, createMasterSlaveEntry, getCfg, getCodec, getCommandExecutor, getConfig, getConnectionEventsHub, getConnectionWatcher, getEntry, getEntry, getEntry, getEntrySet, getExecutor, getGroup, getId, getShutdownLatch, getShutdownPromise, getSubscribeService, initSingleEntry, initTimer, isShutdown, isShuttingDown, newTimeout, releaseRead, releaseWrite, removeEntry, shutdown, startDNSMonitoring, stopThreads

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterConnectionManager

public ClusterConnectionManager(ClusterServersConfig cfg,
                                Config config,
                                UUID id)

Method Detail

createRedisConfig

protected RedisClientConfig createRedisConfig(NodeType type,
                                              URI address,
                                              int timeout,
                                              int commandTimeout,
                                              String sslHostname)

Overrides:

createRedisConfig in class MasterSlaveConnectionManager

getConfigEndpointHostName

public String getConfigEndpointHostName()

calcSlot

public int calcSlot(byte[] key)

Specified by:

calcSlot in interface ConnectionManager

Overrides:

calcSlot in class MasterSlaveConnectionManager

calcSlot

public int calcSlot(String key)

Specified by:

calcSlot in interface ConnectionManager

Overrides:

calcSlot in class MasterSlaveConnectionManager

applyNatMap

public URI applyNatMap(URI address)

Specified by:

applyNatMap in interface ConnectionManager

Overrides:

applyNatMap in class MasterSlaveConnectionManager

shutdown

public void shutdown()

Specified by:

shutdown in interface ConnectionManager

Overrides:

shutdown in class MasterSlaveConnectionManager

getLastClusterNode

public URI getLastClusterNode()

Specified by:

getLastClusterNode in interface ConnectionManager

Overrides:

getLastClusterNode in class MasterSlaveConnectionManager

isClusterMode

public boolean isClusterMode()

Specified by:

isClusterMode in interface ConnectionManager

Overrides:

isClusterMode in class MasterSlaveConnectionManager