Package | Description |
---|---|
io.lettuce.core.cluster |
Client for Redis Cluster, see
RedisClusterClient . |
io.lettuce.core.cluster.api |
Redis Cluster connection API.
|
io.lettuce.core.cluster.models.partitions |
Model and parser for the
CLUSTER NODES and CLUSTER SLAVES output. |
io.lettuce.core.cluster.pubsub |
Redis Cluster Pub/Sub support.
|
io.lettuce.core.cluster.topology |
Support for cluster topology refresh.
|
io.lettuce.core.event.cluster |
Redis Cluster events.
|
Modifier and Type | Method and Description |
---|---|
protected Partitions |
RedisClusterClient.determinePartitions(Partitions current,
Map<RedisURI,Partitions> topologyViews)
Determines a
topology view based on the current and the obtain topology views. |
Partitions |
StatefulRedisClusterConnectionImpl.getPartitions() |
Partitions |
RedisClusterClient.getPartitions()
Retrieve the cluster view.
|
Partitions |
PartitionSelectorException.getPartitions() |
protected Partitions |
RedisClusterClient.loadPartitions()
Retrieve partitions.
|
Modifier and Type | Method and Description |
---|---|
protected Partitions |
RedisClusterClient.determinePartitions(Partitions current,
Map<RedisURI,Partitions> topologyViews)
Determines a
topology view based on the current and the obtain topology views. |
void |
StatefulRedisClusterConnectionImpl.setPartitions(Partitions partitions) |
void |
RedisClusterClient.setPartitions(Partitions partitions)
Sets the new cluster topology.
|
Modifier and Type | Method and Description |
---|---|
protected Partitions |
RedisClusterClient.determinePartitions(Partitions current,
Map<RedisURI,Partitions> topologyViews)
Determines a
topology view based on the current and the obtain topology views. |
protected Mono<SocketAddress> |
RedisClusterClient.getSocketAddressSupplier(Function<Partitions,Collection<RedisClusterNode>> sortFunction)
Returns a
Supplier for connection points . |
Constructor and Description |
---|
PartitionSelectorException(String msg,
Partitions partitions)
Create a
UnknownPartitionException with the specified detail message. |
Modifier and Type | Method and Description |
---|---|
Partitions |
StatefulRedisClusterConnection.getPartitions() |
Modifier and Type | Method and Description |
---|---|
Partitions |
Partitions.clone()
Create a deep copy of this
Partitions object. |
static Partitions |
ClusterPartitionParser.parse(String nodes)
Parse partition lines into Partitions object.
|
Modifier and Type | Method and Description |
---|---|
Partitions |
StatefulRedisClusterPubSubConnection.getPartitions() |
Modifier and Type | Method and Description |
---|---|
Map<RedisURI,Partitions> |
ClusterTopologyRefresh.loadViews(Iterable<RedisURI> seed,
Duration connectTimeout,
boolean discovery)
|
Modifier and Type | Method and Description |
---|---|
RedisURI |
ClusterTopologyRefresh.getViewedBy(Map<RedisURI,Partitions> map,
Partitions partitions)
Resolve a
RedisURI from a map of cluster views by Partitions as key |
static boolean |
TopologyComparators.isChanged(Partitions o1,
Partitions o2)
Check if properties changed which are essential for cluster operations.
|
Modifier and Type | Method and Description |
---|---|
RedisURI |
ClusterTopologyRefresh.getViewedBy(Map<RedisURI,Partitions> map,
Partitions partitions)
Resolve a
RedisURI from a map of cluster views by Partitions as key |
Modifier and Type | Method and Description |
---|---|
Partitions |
AdaptiveRefreshTriggeredEvent.getPartitions()
Retrieve the currently known partitions.
|
Constructor and Description |
---|
AdaptiveRefreshTriggeredEvent(Supplier<Partitions> partitionsSupplier,
Runnable topologyRefreshScheduler) |
Copyright © 2019 lettuce.io. All rights reserved.