Package org.redisson.connection.balancer

Class LoadBalancerManager

org.redisson.connection.balancer.LoadBalancerManager

public class LoadBalancerManager
extends 

Author:

Nikita Koksharov

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
>	add(ClientConnectionsEntry entry)
void	address, NodeType nodeType)
boolean	addr)
boolean	contains(RedisClient redisClient)
boolean	contains(RedisURI addr)
ClientConnectionsEntry	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)
<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)
>	shutdownAsync()
boolean	address, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	unfreeze(ClientConnectionsEntry entry, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	unfreeze(RedisURI address, ClientConnectionsEntry.FreezeReason freezeReason)

Methods inherited from class java.lang.

, , , , , , , , , ,

Constructor Detail

LoadBalancerManager

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

Method Detail

changeType

public void changeType( address,
                       NodeType nodeType)

add

public > add(ClientConnectionsEntry entry)

getEntries

public <ClientConnectionsEntry> getEntries()

getAvailableSlaves

public int getAvailableSlaves()

getAvailableClients

public int getAvailableClients()

unfreeze

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

unfreeze

public boolean unfreeze( address,
                        ClientConnectionsEntry.FreezeReason freezeReason)

unfreeze

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

freeze

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

freeze

public  address,
                                     ClientConnectionsEntry.FreezeReason freezeReason)

freeze

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

nextPubSubConnection

public RFuture<RedisPubSubConnection> nextPubSubConnection()

contains

public boolean contains( 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 > shutdownAsync()