Package org.redisson.connection

Class MasterSlaveEntry

org.redisson.connection.MasterSlaveEntry

Direct Known Subclasses:

SingleEntry

public class MasterSlaveEntry
extends 

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
MasterSlaveEntry(ConnectionManager connectionManager, MasterSlaveServersConfig config, sslHostname)

Method Summary

Modifier and Type	Method	Description
>	address, RedisURI uri)
>	addSlave(RedisURI address)
RFuture<RedisClient>	address, RedisURI uri)
RFuture<RedisClient>	changeMaster(RedisURI address)	Freeze slave with redis(s)://host:port from slaves list.
RFuture<RedisConnection>	connectionReadOp(RedisCommand<?> command)
RFuture<RedisConnection>	connectionReadOp(RedisCommand<?> command, RedisClient client)
RFuture<RedisConnection>	connectionReadOp(RedisCommand<?> command, RedisURI addr)
RFuture<RedisConnection>	connectionWriteOp(RedisCommand<?> command)
int	decReference()
<ClientConnectionsEntry>	getAllEntries()
int	getAvailableClients()
int	getAvailableSlaves()
RedisClient	getClient()
MasterSlaveServersConfig	getConfig()
ClientConnectionsEntry	getEntry(RedisClient redisClient)
int	getReferences()
boolean	addr)
boolean	hasSlave(RedisClient redisClient)
boolean	hasSlave(RedisURI addr)
void	incReference()
<>>	<RedisURI> disconnectedNodes, RedisClient master)
boolean	isSlaveUnfreezed(RedisURI address)
void	masterDown()
RFuture<RedisPubSubConnection>	nextPubSubConnection()
boolean	nodeDown(ClientConnectionsEntry entry)
RFuture<RedisConnection>	redirectedConnectionWriteOp(RedisCommand<?> command, RedisURI addr)
void	releaseRead(RedisConnection connection)
void	releaseWrite(RedisConnection connection)
void	returnPubSubConnection(RedisPubSubConnection connection)
RFuture<RedisClient>	address, RedisURI uri)
RFuture<RedisClient>	setupMasterEntry(RedisURI address)
>	shutdownAsync()
boolean	address, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	slaveDown(ClientConnectionsEntry entry, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	slaveDown(RedisURI address, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	address, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	slaveUp(ClientConnectionsEntry entry, ClientConnectionsEntry.FreezeReason freezeReason)
boolean	slaveUp(RedisURI address, ClientConnectionsEntry.FreezeReason freezeReason)
	toString()

Methods inherited from class java.lang.

, , , , , , , , ,

Constructor Detail

MasterSlaveEntry

public MasterSlaveEntry(ConnectionManager connectionManager,
                        MasterSlaveServersConfig config,
                         sslHostname)

Method Detail

getConfig

public MasterSlaveServersConfig getConfig()

initSlaveBalancer

public <>> initSlaveBalancer(<RedisURI> disconnectedNodes,
                                             RedisClient master)

setupMasterEntry

public  address,
                                             RedisURI uri)

setupMasterEntry

public RFuture<RedisClient> setupMasterEntry(RedisURI address)

slaveDown

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

slaveDown

public boolean slaveDown( address,
                         ClientConnectionsEntry.FreezeReason freezeReason)

slaveDown

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

masterDown

public void masterDown()

nodeDown

public boolean nodeDown(ClientConnectionsEntry entry)

hasSlave

public boolean hasSlave(RedisClient redisClient)

hasSlave

public boolean hasSlave( addr)

hasSlave

public boolean hasSlave(RedisURI addr)

getAvailableSlaves

public int getAvailableSlaves()

getAvailableClients

public int getAvailableClients()

addSlave

public > addSlave(RedisURI address)

addSlave

public > addSlave( address,
                              RedisURI uri)

getAllEntries

public <ClientConnectionsEntry> getAllEntries()

getEntry

public ClientConnectionsEntry getEntry(RedisClient redisClient)

getClient

public RedisClient getClient()

slaveUp

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

isSlaveUnfreezed

public boolean isSlaveUnfreezed(RedisURI address)

slaveUp

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

slaveUp

public boolean slaveUp( address,
                       ClientConnectionsEntry.FreezeReason freezeReason)

changeMaster

public RFuture<RedisClient> changeMaster(RedisURI address)

Freeze slave with redis(s)://host:port from slaves list. Re-attach pub/sub listeners from it to other slave. Shutdown old master client.

Parameters:

address - of Redis

Returns:

client

changeMaster

public  address,
                                         RedisURI uri)

shutdownAsync

public > shutdownAsync()

connectionWriteOp

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

redirectedConnectionWriteOp

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

connectionReadOp

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

connectionReadOp

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

connectionReadOp

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

nextPubSubConnection

public RFuture<RedisPubSubConnection> nextPubSubConnection()

returnPubSubConnection

public void returnPubSubConnection(RedisPubSubConnection connection)

releaseWrite

public void releaseWrite(RedisConnection connection)

releaseRead

public void releaseRead(RedisConnection connection)

incReference

public void incReference()

decReference

public int decReference()

getReferences

public int getReferences()

toString

public  toString()

Overrides:

in class