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 and Description
ClusterTopology(Set<RedisClusterNode> nodes) Creates new instance of ClusterTopology.

Method Summary

Modifier and Type	Method and 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 slave) 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 slave) serving s specific slot.
RedisClusterNode	lookup(RedisClusterNode node) Get the RedisClusterNode matching matching either host and port or nodeId
RedisClusterNode	lookup(String nodeId) Get the RedisClusterNode matching given nodeId.
RedisClusterNode	lookup(String host, int port) Get the RedisClusterNode matching given host and port.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterTopology

public ClusterTopology(@Nullable
                       Set<RedisClusterNode> nodes)

Creates new instance of ClusterTopology.

Parameters:

nodes - can be null.

Method Detail

getNodes

public Set<RedisClusterNode> getNodes()

Get all RedisClusterNodes.

Returns:

never null.

getActiveNodes

public Set<RedisClusterNode> getActiveNodes()

Get all nodes (master and slave) 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 slave) 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.