io.lettuce.core.cluster.topology

Class ClusterTopologyRefresh

java.lang.Object

io.lettuce.core.cluster.topology.ClusterTopologyRefresh

public class ClusterTopologyRefresh
extends Object

Utility to refresh the cluster topology view based on Partitions.

Author:

Mark Paluch

Constructor Summary

Constructors

Constructor and Description
ClusterTopologyRefresh(NodeConnectionFactory nodeConnectionFactory, ClientResources clientResources)

Method Summary

Modifier and Type	Method and Description
RedisURI	getViewedBy(Map<RedisURI,Partitions> map, Partitions partitions) Resolve a RedisURI from a map of cluster views by Partitions as key
Map<RedisURI,Partitions>	loadViews(Iterable<RedisURI> seed, Duration connectTimeout, boolean discovery) Load partition views from a collection of RedisURIs and return the view per RedisURI.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterTopologyRefresh

public ClusterTopologyRefresh(NodeConnectionFactory nodeConnectionFactory,
                              ClientResources clientResources)

Method Detail

loadViews

public Map<RedisURI,Partitions> loadViews(Iterable<RedisURI> seed,
                                          Duration connectTimeout,
                                          boolean discovery)

Load partition views from a collection of RedisURIs and return the view per RedisURI. Partitions contain an ordered list of RedisClusterNodes. The sort key is latency. Nodes with lower latency come first.

Parameters:

seed - collection of RedisURIs

connectTimeout - connect timeout

discovery - true to discover additional nodes

Returns:

mapping between RedisURI and Partitions

getViewedBy

public RedisURI getViewedBy(Map<RedisURI,Partitions> map,
                            Partitions partitions)

Resolve a RedisURI from a map of cluster views by Partitions as key

Parameters:

map - the map

partitions - the key

Returns:

a RedisURI or null