Package org.springframework.data.redis.connection

Class ClusterTopology

java.lang.Object

org.springframework.data.redis.connection.ClusterTopology

public class ClusterTopology
extends Object

ClusterTopology holds snapshot like information about RedisClusterNodes.

Since:

1.7

Author:

Christoph Strobl, Mark Paluch

Constructor Summary

Constructors

Constructor	Description
ClusterTopology(Set<RedisClusterNode> nodes)	Creates new instance of ClusterTopology.

Method Summary

Modifier and Type	Method	Description
Set<RedisClusterNode>	getActiveMasterNodes()	Get all master nodes in cluster where link-state is connected and flags does not contain fail or fail?.
Set<RedisClusterNode>	getActiveNodes()	Get all nodes (master and replica) in cluster where link-state is connected and flags does not contain fail or fail?.
RedisClusterNode	getKeyServingMasterNode(byte[] key)	Get the RedisClusterNode that is the current master serving the given key.
Set<RedisClusterNode>	getKeyServingNodes(byte[] key)
Set<RedisClusterNode>	getMasterNodes()	Get all master nodes in cluster.
Set<RedisClusterNode>	getNodes()	Get all RedisClusterNodes.
Set<RedisClusterNode>	getSlotServingNodes(int slot)	Get the RedisClusterNodes (master and replica) serving s specific slot.
RedisClusterNode	lookup(String nodeId)	Get the RedisClusterNode matching given nodeId.
RedisClusterNode	lookup(String host, int port)	Get the RedisClusterNode matching given host and port.
RedisClusterNode	lookup(RedisClusterNode node)	Get the RedisClusterNode matching matching either host and port or nodeId

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterTopology

public ClusterTopology(@Nullable
 Set<RedisClusterNode> nodes)

Creates new instance of ClusterTopology.

Parameters:

nodes - can be null.

Method Details

getNodes

public Set<RedisClusterNode> getNodes()

Get all RedisClusterNodes.

Returns:

never null.

getActiveNodes

public Set<RedisClusterNode> getActiveNodes()

Get all nodes (master and replica) in cluster where link-state is connected and flags does not contain fail or fail?.

Returns:

never null.

getActiveMasterNodes

public Set<RedisClusterNode> getActiveMasterNodes()

Get all master nodes in cluster where link-state is connected and flags does not contain fail or fail?.

Returns:

never null.

getMasterNodes

public Set<RedisClusterNode> getMasterNodes()

Get all master nodes in cluster.

Returns:

never null.

getSlotServingNodes

public Set<RedisClusterNode> getSlotServingNodes(int slot)

Get the RedisClusterNodes (master and replica) serving s specific slot.

Parameters:

slot -

Returns:

never null.

getKeyServingMasterNode

public RedisClusterNode getKeyServingMasterNode(byte[] key)

Get the RedisClusterNode that is the current master serving the given key.

Parameters:

key - must not be null.

Returns:

never null.

Throws:

ClusterStateFailureException

lookup

public RedisClusterNode lookup(String host,
 int port)

Get the RedisClusterNode matching given host and port.

Parameters:

host - must not be null.

port -

Returns:

never null.

Throws:

ClusterStateFailureException

lookup

public RedisClusterNode lookup(String nodeId)

Get the RedisClusterNode matching given nodeId.

Parameters:

nodeId - must not be null.

Returns:

never null.

Throws:

ClusterStateFailureException

lookup

public RedisClusterNode lookup(RedisClusterNode node)

Get the RedisClusterNode matching matching either host and port or nodeId

Parameters:

node - must not be null

Returns:

never null.

Throws:

ClusterStateFailureException

getKeyServingNodes

public Set<RedisClusterNode> getKeyServingNodes(byte[] key)

Parameters:

key - must not be null.

Returns:

null.