Package org.redisson.connection.balancer

Class LoadBalancerManager

java.lang.Object

org.redisson.connection.balancer.LoadBalancerManager

public class LoadBalancerManager
extends Object

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
LoadBalancerManager(MasterSlaveServersConfig config, ConnectionManager connectionManager, MasterSlaveEntry entry)

Method Summary

Modifier and Type	Method	Description
RFuture<Void>	add(ClientConnectionsEntry entry)
void	changeType(InetSocketAddress address, NodeType nodeType)
boolean	contains(InetSocketAddress addr)
boolean	contains(RedisClient redisClient)
boolean	contains(RedisURI addr)
ClientConnectionsEntry	freeze(InetSocketAddress address, ClientConnectionsEntry.FreezeReason freezeReason)
ClientConnectionsEntry	freeze(ClientConnectionsEntry connectionEntry, ClientConnectionsEntry.FreezeReason freezeReason)
ClientConnectionsEntry	freeze(RedisURI address, ClientConnectionsEntry.FreezeReason freezeReason)
int	getAvailableClients()
int	getAvailableSlaves()
RFuture<RedisConnection>	getConnection(RedisCommand<?> command, RedisClient client)
RFuture<RedisConnection>	getConnection(RedisCommand<?> command, RedisURI addr)
Collection<ClientConnectionsEntry>	getEntries()
ClientConnectionsEntry	getEntry(RedisClient redisClient)
boolean	isUnfreezed(RedisURI addr)
RFuture<RedisConnection>	nextConnection(RedisCommand<?> command)
RFuture<RedisPubSubConnection>	nextPubSubConnection()
void	returnConnection(RedisConnection connection)
void	returnPubSubConnection(RedisPubSubConnection connection)
RFuture<Void>	shutdownAsync()
boolean	unfreeze(InetSocketAddress address, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	unfreeze(ClientConnectionsEntry entry, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	unfreeze(RedisURI address, ClientConnectionsEntry.FreezeReason freezeReason)

Methods inherited from class java.lang.Object

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

Constructor Detail

LoadBalancerManager

public LoadBalancerManager(MasterSlaveServersConfig config,
                           ConnectionManager connectionManager,
                           MasterSlaveEntry entry)

Method Detail

changeType

public void changeType(InetSocketAddress address,
                       NodeType nodeType)

add

public RFuture<Void> add(ClientConnectionsEntry entry)

getEntries

public Collection<ClientConnectionsEntry> getEntries()

getAvailableSlaves

public int getAvailableSlaves()

getAvailableClients

public int getAvailableClients()

unfreeze

public boolean unfreeze(RedisURI address,
                        ClientConnectionsEntry.FreezeReason freezeReason)

unfreeze

public boolean unfreeze(InetSocketAddress address,
                        ClientConnectionsEntry.FreezeReason freezeReason)

unfreeze

public boolean unfreeze(ClientConnectionsEntry entry,
                        ClientConnectionsEntry.FreezeReason freezeReason)

freeze

public ClientConnectionsEntry freeze(RedisURI address,
                                     ClientConnectionsEntry.FreezeReason freezeReason)

freeze

public ClientConnectionsEntry freeze(InetSocketAddress address,
                                     ClientConnectionsEntry.FreezeReason freezeReason)

freeze

public ClientConnectionsEntry freeze(ClientConnectionsEntry connectionEntry,
                                     ClientConnectionsEntry.FreezeReason freezeReason)

nextPubSubConnection

public RFuture<RedisPubSubConnection> nextPubSubConnection()

contains

public boolean contains(InetSocketAddress addr)

isUnfreezed

public boolean isUnfreezed(RedisURI addr)

contains

public boolean contains(RedisURI addr)

contains

public boolean contains(RedisClient redisClient)

getEntry

public ClientConnectionsEntry getEntry(RedisClient redisClient)

getConnection

public RFuture<RedisConnection> getConnection(RedisCommand<?> command,
                                              RedisURI addr)

getConnection

public RFuture<RedisConnection> getConnection(RedisCommand<?> command,
                                              RedisClient client)

nextConnection

public RFuture<RedisConnection> nextConnection(RedisCommand<?> command)

returnPubSubConnection

public void returnPubSubConnection(RedisPubSubConnection connection)

returnConnection

public void returnConnection(RedisConnection connection)

shutdownAsync

public RFuture<Void> shutdownAsync()