Package org.redisson.connection

Interface ConnectionManager

All Known Implementing Classes:

ClusterConnectionManager, MasterSlaveConnectionManager, ReplicatedConnectionManager, SentinelConnectionManager, SingleConnectionManager

public interface ConnectionManager

Author:

Nikita Koksharov

Method Summary

Modifier and Type	Method	Description
RedisURI	applyNatMap(RedisURI address)
int	calcSlot(byte[] key)
int	calcSlot(String key)
RFuture<RedisConnection>	connectionReadOp(NodeSource source, RedisCommand<?> command)
RFuture<RedisConnection>	connectionWriteOp(NodeSource source, RedisCommand<?> command)
RedisClient	createClient(NodeType type, InetSocketAddress address, RedisURI uri, String sslHostname)
RedisClient	createClient(NodeType type, RedisURI address, int timeout, int commandTimeout, String sslHostname)
RedisClient	createClient(NodeType type, RedisURI address, String sslHostname)
RedisNodeNotFoundException	createNodeNotFoundException(NodeSource source)
Config	getCfg()
Codec	getCodec()
MasterSlaveServersConfig	getConfig()
ConnectionEventsHub	getConnectionEventsHub()
IdleConnectionWatcher	getConnectionWatcher()
ElementsSubscribeService	getElementsSubscribeService()
MasterSlaveEntry	getEntry(int slot)
MasterSlaveEntry	getEntry(String name)
MasterSlaveEntry	getEntry(InetSocketAddress address)
MasterSlaveEntry	getEntry(RedisClient redisClient)
Collection<MasterSlaveEntry>	getEntrySet()
ExecutorService	getExecutor()
io.netty.channel.EventLoopGroup	getGroup()
String	getId()
RedisURI	getLastClusterNode()
InfinitySemaphoreLatch	getShutdownLatch()
io.netty.util.concurrent.Future<Void>	getShutdownPromise()
PublishSubscribeService	getSubscribeService()
boolean	isClusterMode()
boolean	isShutdown()
boolean	isShuttingDown()
io.netty.util.Timeout	newTimeout(io.netty.util.TimerTask task, long delay, TimeUnit unit)
void	releaseRead(NodeSource source, RedisConnection connection)
void	releaseWrite(NodeSource source, RedisConnection connection)
void	shutdown()
void	shutdown(long quietPeriod, long timeout, TimeUnit unit)

Method Detail

applyNatMap

RedisURI applyNatMap(RedisURI address)

getId

String getId()

getElementsSubscribeService

ElementsSubscribeService getElementsSubscribeService()

getSubscribeService

PublishSubscribeService getSubscribeService()

getExecutor

ExecutorService getExecutor()

getLastClusterNode

RedisURI getLastClusterNode()

getCfg

Config getCfg()

isClusterMode

boolean isClusterMode()

getConnectionEventsHub

ConnectionEventsHub getConnectionEventsHub()

isShutdown

boolean isShutdown()

isShuttingDown

boolean isShuttingDown()

getConnectionWatcher

IdleConnectionWatcher getConnectionWatcher()

calcSlot

int calcSlot(String key)

calcSlot

int calcSlot(byte[] key)

getConfig

MasterSlaveServersConfig getConfig()

getCodec

Codec getCodec()

getEntrySet

Collection<MasterSlaveEntry> getEntrySet()

getEntry

MasterSlaveEntry getEntry(String name)

getEntry

MasterSlaveEntry getEntry(int slot)

getEntry

MasterSlaveEntry getEntry(InetSocketAddress address)

releaseRead

void releaseRead(NodeSource source,
                 RedisConnection connection)

releaseWrite

void releaseWrite(NodeSource source,
                  RedisConnection connection)

connectionReadOp

RFuture<RedisConnection> connectionReadOp(NodeSource source,
                                          RedisCommand<?> command)

connectionWriteOp

RFuture<RedisConnection> connectionWriteOp(NodeSource source,
                                           RedisCommand<?> command)

createClient

RedisClient createClient(NodeType type,
                         RedisURI address,
                         int timeout,
                         int commandTimeout,
                         String sslHostname)

createClient

RedisClient createClient(NodeType type,
                         InetSocketAddress address,
                         RedisURI uri,
                         String sslHostname)

createClient

RedisClient createClient(NodeType type,
                         RedisURI address,
                         String sslHostname)

getEntry

MasterSlaveEntry getEntry(RedisClient redisClient)

shutdown

void shutdown()

shutdown

void shutdown(long quietPeriod,
              long timeout,
              TimeUnit unit)

getGroup

io.netty.channel.EventLoopGroup getGroup()

newTimeout

io.netty.util.Timeout newTimeout(io.netty.util.TimerTask task,
                                 long delay,
                                 TimeUnit unit)

getShutdownLatch

InfinitySemaphoreLatch getShutdownLatch()

getShutdownPromise

io.netty.util.concurrent.Future<Void> getShutdownPromise()

createNodeNotFoundException

RedisNodeNotFoundException createNodeNotFoundException(NodeSource source)