Package org.redisson.connection

Class ClientConnectionsEntry

java.lang.Object

org.redisson.connection.ClientConnectionsEntry

public class ClientConnectionsEntry
extends Object

Author:

Nikita Koksharov

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ClientConnectionsEntry.FreezeReason

Constructor Summary

Constructors

Constructor	Description
ClientConnectionsEntry(RedisClient client, int poolMinSize, int poolMaxSize, ConnectionManager connectionManager, NodeType nodeType, MasterSlaveServersConfig config)

Method Summary

Modifier and Type	Method	Description
RedisClient	getClient()
ConnectionsHolder<RedisConnection>	getConnectionsHolder()
ClientConnectionsEntry.FreezeReason	getFreezeReason()
WrappedLock	getLock()
NodeType	getNodeType()
ConnectionsHolder<RedisPubSubConnection>	getPubSubConnectionsHolder()
CompletableFuture<Void>	initConnections(int minimumIdleSize)
CompletableFuture<Void>	initPubSubConnections(int minimumIdleSize)
boolean	isFreezed()
boolean	isInitialized()
boolean	isMasterForRead()
void	nodeDown()
void	reattachPubSub()
void	setFreezeReason(ClientConnectionsEntry.FreezeReason freezeReason)
void	setInitialized(boolean isInited)
void	setNodeType(NodeType nodeType)
CompletableFuture<Void>	shutdownAsync()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ClientConnectionsEntry

public ClientConnectionsEntry(RedisClient client,
 int poolMinSize,
 int poolMaxSize,
 ConnectionManager connectionManager,
 NodeType nodeType,
 MasterSlaveServersConfig config)

Method Details

initConnections

public CompletableFuture<Void> initConnections(int minimumIdleSize)

initPubSubConnections

public CompletableFuture<Void> initPubSubConnections(int minimumIdleSize)

isMasterForRead

public boolean isMasterForRead()

isInitialized

public boolean isInitialized()

setInitialized

public void setInitialized(boolean isInited)

setNodeType

public void setNodeType(NodeType nodeType)

getNodeType

public NodeType getNodeType()

shutdownAsync

public CompletableFuture<Void> shutdownAsync()

getClient

public RedisClient getClient()

isFreezed

public boolean isFreezed()

setFreezeReason

public void setFreezeReason(ClientConnectionsEntry.FreezeReason freezeReason)

getFreezeReason

public ClientConnectionsEntry.FreezeReason getFreezeReason()

getLock

public WrappedLock getLock()

reattachPubSub

public void reattachPubSub()

nodeDown

public void nodeDown()

getConnectionsHolder

public ConnectionsHolder<RedisConnection> getConnectionsHolder()

getPubSubConnectionsHolder

public ConnectionsHolder<RedisPubSubConnection> getPubSubConnectionsHolder()

toString

public String toString()

Overrides:

toString in class Object