Uses of Class
io.lettuce.core.cluster.models.partitions.RedisClusterNode
-
Packages that use RedisClusterNode Package Description io.lettuce.core.cluster Client for Redis Cluster, seeRedisClusterClient
.io.lettuce.core.cluster.api Redis Cluster connection API.io.lettuce.core.cluster.api.async Redis Cluster API for asynchronous executed commands.io.lettuce.core.cluster.api.push Interfaces to consume push messages using Redis Cluster.io.lettuce.core.cluster.api.reactive Redis Cluster API for reactive command execution.io.lettuce.core.cluster.api.sync Redis Cluster API for synchronous executed commands.io.lettuce.core.cluster.event Cluster event types.io.lettuce.core.cluster.models.partitions Model and parser for theCLUSTER NODES
andCLUSTER SLAVES
output.io.lettuce.core.cluster.models.slots Model and parser for theCLUSTER SLOTS
output.io.lettuce.core.cluster.pubsub Redis Cluster Pub/Sub support.io.lettuce.core.cluster.pubsub.api.async Redis Cluster Pub/Sub API for asynchronous executed commands.io.lettuce.core.cluster.pubsub.api.reactive Redis Cluster Pub/Sub API for reactive command execution.io.lettuce.core.cluster.pubsub.api.sync Redis Cluster Pub/Sub API for synchronous executed commands.io.lettuce.core.cluster.topology Support for cluster topology refresh. -
-
Uses of RedisClusterNode in io.lettuce.core.cluster
Fields in io.lettuce.core.cluster with type parameters of type RedisClusterNode Modifier and Type Field Description static Predicate<RedisClusterNode>
ClusterClientOptions. DEFAULT_NODE_FILTER
Methods in io.lettuce.core.cluster that return types with arguments of type RedisClusterNode Modifier and Type Method Description Predicate<RedisClusterNode>
ClusterClientOptions. getNodeFilter()
Thenode filter
to filter Redis Cluster nodes fromPartitions
.Method parameters in io.lettuce.core.cluster with type arguments of type RedisClusterNode Modifier and Type Method Description protected <T> Map<String,org.reactivestreams.Publisher<T>>
RedisAdvancedClusterReactiveCommandsImpl. executeOnNodes(Function<RedisClusterReactiveCommands<K,V>,? extends org.reactivestreams.Publisher<T>> function, Predicate<RedisClusterNode> filter)
Run a command on all available nodes that matchfilter
.protected Mono<SocketAddress>
RedisClusterClient. getSocketAddressSupplier(Supplier<Partitions> partitionsSupplier, Function<Partitions,Collection<RedisClusterNode>> sortFunction)
Returns aSupplier
forconnection points
.ClusterClientOptions.Builder
ClusterClientOptions.Builder. nodeFilter(Predicate<RedisClusterNode> nodeFilter)
Provide anode filter
to filter cluster nodes fromPartitions
.AsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommandsImpl. nodes(Predicate<RedisClusterNode> predicate)
AsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommandsImpl. nodes(Predicate<RedisClusterNode> predicate, boolean dynamic)
protected AsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommandsImpl. nodes(Predicate<RedisClusterNode> predicate, ConnectionIntent connectionIntent, boolean dynamic)
PubSubAsyncNodeSelection<K,V>
RedisClusterPubSubAsyncCommandsImpl. nodes(Predicate<RedisClusterNode> predicate)
PubSubReactiveNodeSelection<K,V>
RedisClusterPubSubReactiveCommandsImpl. nodes(Predicate<RedisClusterNode> predicate)
AsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommandsImpl. readonly(Predicate<RedisClusterNode> predicate)
-
Uses of RedisClusterNode in io.lettuce.core.cluster.api
Methods in io.lettuce.core.cluster.api that return RedisClusterNode Modifier and Type Method Description RedisClusterNode
NodeSelectionSupport. node(int index)
Get theRedisClusterNode
.Methods in io.lettuce.core.cluster.api that return types with arguments of type RedisClusterNode Modifier and Type Method Description Map<RedisClusterNode,API>
NodeSelectionSupport. asMap()
-
Uses of RedisClusterNode in io.lettuce.core.cluster.api.async
Methods in io.lettuce.core.cluster.api.async that return types with arguments of type RedisClusterNode Modifier and Type Method Description Map<RedisClusterNode,CompletableFuture<T>>
AsyncExecutions. asMap()
Collection<RedisClusterNode>
AsyncExecutions. nodes()
Methods in io.lettuce.core.cluster.api.async with parameters of type RedisClusterNode Modifier and Type Method Description CompletionStage<T>
AsyncExecutions. get(RedisClusterNode redisClusterNode)
Method parameters in io.lettuce.core.cluster.api.async with type arguments of type RedisClusterNode Modifier and Type Method Description AsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommands. nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate and keeps a static selection.AsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommands. nodes(Predicate<RedisClusterNode> predicate, boolean dynamic)
Select nodes by a predicateAsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommands. readonly(Predicate<RedisClusterNode> predicate)
Select replica nodes by a predicate and keeps a static selection.default AsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommands. replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.default AsyncNodeSelection<K,V>
RedisAdvancedClusterAsyncCommands. slaves(Predicate<RedisClusterNode> predicate)
Deprecated. -
Uses of RedisClusterNode in io.lettuce.core.cluster.api.push
Methods in io.lettuce.core.cluster.api.push with parameters of type RedisClusterNode Modifier and Type Method Description void
RedisClusterPushListener. onPushMessage(RedisClusterNode node, PushMessage message)
Handle a push message. -
Uses of RedisClusterNode in io.lettuce.core.cluster.api.reactive
Methods in io.lettuce.core.cluster.api.reactive that return types with arguments of type RedisClusterNode Modifier and Type Method Description Collection<RedisClusterNode>
ReactiveExecutions. nodes()
-
Uses of RedisClusterNode in io.lettuce.core.cluster.api.sync
Methods in io.lettuce.core.cluster.api.sync that return types with arguments of type RedisClusterNode Modifier and Type Method Description Map<RedisClusterNode,T>
Executions. asMap()
Collection<RedisClusterNode>
Executions. nodes()
Methods in io.lettuce.core.cluster.api.sync with parameters of type RedisClusterNode Modifier and Type Method Description T
Executions. get(RedisClusterNode redisClusterNode)
Method parameters in io.lettuce.core.cluster.api.sync with type arguments of type RedisClusterNode Modifier and Type Method Description NodeSelection<K,V>
RedisAdvancedClusterCommands. nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate and keeps a static selection.NodeSelection<K,V>
RedisAdvancedClusterCommands. nodes(Predicate<RedisClusterNode> predicate, boolean dynamic)
Select nodes by a predicateNodeSelection<K,V>
RedisAdvancedClusterCommands. readonly(Predicate<RedisClusterNode> predicate)
Select replica nodes by a predicate and keeps a static selection.default NodeSelection<K,V>
RedisAdvancedClusterCommands. replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.default NodeSelection<K,V>
RedisAdvancedClusterCommands. slaves(Predicate<RedisClusterNode> predicate)
Deprecated.since 5.2, useRedisAdvancedClusterCommands.replicas(Predicate)
-
Uses of RedisClusterNode in io.lettuce.core.cluster.event
Methods in io.lettuce.core.cluster.event that return types with arguments of type RedisClusterNode Modifier and Type Method Description List<RedisClusterNode>
ClusterTopologyChangedEvent. after()
Returns the cluster topology view after the topology changed.List<RedisClusterNode>
ClusterTopologyChangedEvent. before()
Returns the cluster topology view before the topology changed.Constructor parameters in io.lettuce.core.cluster.event with type arguments of type RedisClusterNode Constructor Description ClusterTopologyChangedEvent(List<RedisClusterNode> before, List<RedisClusterNode> after)
Creates a newClusterTopologyChangedEvent
. -
Uses of RedisClusterNode in io.lettuce.core.cluster.models.partitions
Methods in io.lettuce.core.cluster.models.partitions that return RedisClusterNode Modifier and Type Method Description RedisClusterNode
RedisClusterNode. clone()
Clonethis
RedisClusterNode
.RedisClusterNode
Partitions. getMasterBySlot(int slot)
Retrieve amaster node
by its slot numberRedisClusterNode
Partitions. getPartition(int index)
Returns theRedisClusterNode
atindex
.RedisClusterNode
Partitions. getPartition(String host, int port)
Retrieve aRedisClusterNode
by its hostname/port considering node aliases.RedisClusterNode
Partitions. getPartitionByNodeId(String nodeId)
Retrieve aRedisClusterNode
by its node id.RedisClusterNode
Partitions. getPartitionBySlot(int slot)
Retrieve aRedisClusterNode
by its slot number.static RedisClusterNode
RedisClusterNode. of(String nodeId)
Create a new instance ofRedisClusterNode
by passing thenodeId
Methods in io.lettuce.core.cluster.models.partitions that return types with arguments of type RedisClusterNode Modifier and Type Method Description List<RedisClusterNode>
Partitions. getPartitions()
Returns the internalList
ofRedisClusterNode
that holds the partition source.Iterator<RedisClusterNode>
Partitions. iterator()
Returns an iterator over thenodes
in thisPartitions
from the read-view.Methods in io.lettuce.core.cluster.models.partitions with parameters of type RedisClusterNode Modifier and Type Method Description boolean
Partitions. add(RedisClusterNode redisClusterNode)
Adds theRedisClusterNode
to thisPartitions
.void
Partitions. addPartition(RedisClusterNode partition)
Adds a partition without updating the read view/cache.boolean
RedisClusterNode. hasSameSlotsAs(RedisClusterNode other)
Method parameters in io.lettuce.core.cluster.models.partitions with type arguments of type RedisClusterNode Modifier and Type Method Description boolean
Partitions. addAll(Collection<? extends RedisClusterNode> c)
Add allnodes
from the given collection and update the read-view/caches.void
Partitions. reload(List<RedisClusterNode> partitions)
Update partitions and rebuild slot cache.Constructors in io.lettuce.core.cluster.models.partitions with parameters of type RedisClusterNode Constructor Description RedisClusterNode(RedisClusterNode redisClusterNode)
-
Uses of RedisClusterNode in io.lettuce.core.cluster.models.slots
Methods in io.lettuce.core.cluster.models.slots that return RedisClusterNode Modifier and Type Method Description RedisClusterNode
ClusterSlotRange. getUpstream()
Methods in io.lettuce.core.cluster.models.slots that return types with arguments of type RedisClusterNode Modifier and Type Method Description List<RedisClusterNode>
ClusterSlotRange. getReplicaNodes()
List<RedisClusterNode>
ClusterSlotRange. getSlaveNodes()
Deprecated.Methods in io.lettuce.core.cluster.models.slots with parameters of type RedisClusterNode Modifier and Type Method Description void
ClusterSlotRange. setUpstream(RedisClusterNode upstream)
Method parameters in io.lettuce.core.cluster.models.slots with type arguments of type RedisClusterNode Modifier and Type Method Description void
ClusterSlotRange. setReplicaNodes(List<RedisClusterNode> replicaNodes)
void
ClusterSlotRange. setSlaveNodes(List<RedisClusterNode> slaveNodes)
Deprecated.Constructors in io.lettuce.core.cluster.models.slots with parameters of type RedisClusterNode Constructor Description ClusterSlotRange(int from, int to, RedisClusterNode upstream, List<RedisClusterNode> replicaNodes)
Constructs aClusterSlotRange
Constructor parameters in io.lettuce.core.cluster.models.slots with type arguments of type RedisClusterNode Constructor Description ClusterSlotRange(int from, int to, RedisClusterNode upstream, List<RedisClusterNode> replicaNodes)
Constructs aClusterSlotRange
-
Uses of RedisClusterNode in io.lettuce.core.cluster.pubsub
Methods in io.lettuce.core.cluster.pubsub with parameters of type RedisClusterNode Modifier and Type Method Description void
RedisClusterPubSubAdapter. message(RedisClusterNode node, K pattern, K channel, V message)
void
RedisClusterPubSubAdapter. message(RedisClusterNode node, K channel, V message)
void
RedisClusterPubSubListener. message(RedisClusterNode node, K pattern, K channel, V message)
Message received from a pattern subscription.void
RedisClusterPubSubListener. message(RedisClusterNode node, K channel, V message)
Message received from a channel subscription.void
RedisClusterPubSubAdapter. psubscribed(RedisClusterNode node, K pattern, long count)
void
RedisClusterPubSubListener. psubscribed(RedisClusterNode node, K pattern, long count)
Subscribed to a pattern.void
RedisClusterPubSubAdapter. punsubscribed(RedisClusterNode node, K pattern, long count)
void
RedisClusterPubSubListener. punsubscribed(RedisClusterNode node, K pattern, long count)
Unsubscribed from a pattern.void
RedisClusterPubSubAdapter. subscribed(RedisClusterNode node, K channel, long count)
void
RedisClusterPubSubListener. subscribed(RedisClusterNode node, K channel, long count)
Subscribed to a channel.void
RedisClusterPubSubAdapter. unsubscribed(RedisClusterNode node, K channel, long count)
void
RedisClusterPubSubListener. unsubscribed(RedisClusterNode node, K channel, long count)
Unsubscribed from a channel. -
Uses of RedisClusterNode in io.lettuce.core.cluster.pubsub.api.async
Method parameters in io.lettuce.core.cluster.pubsub.api.async with type arguments of type RedisClusterNode Modifier and Type Method Description PubSubAsyncNodeSelection<K,V>
RedisClusterPubSubAsyncCommands. nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate.default PubSubAsyncNodeSelection<K,V>
RedisClusterPubSubAsyncCommands. replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.default PubSubAsyncNodeSelection<K,V>
RedisClusterPubSubAsyncCommands. slaves(Predicate<RedisClusterNode> predicate)
Deprecated.since 5.2, useRedisClusterPubSubAsyncCommands.replicas(Predicate)
-
Uses of RedisClusterNode in io.lettuce.core.cluster.pubsub.api.reactive
Method parameters in io.lettuce.core.cluster.pubsub.api.reactive with type arguments of type RedisClusterNode Modifier and Type Method Description PubSubReactiveNodeSelection<K,V>
RedisClusterPubSubReactiveCommands. nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate.default PubSubReactiveNodeSelection<K,V>
RedisClusterPubSubReactiveCommands. replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.default PubSubReactiveNodeSelection<K,V>
RedisClusterPubSubReactiveCommands. slaves(Predicate<RedisClusterNode> predicate)
Deprecated.since 5.2, useRedisClusterPubSubReactiveCommands.replicas()
. -
Uses of RedisClusterNode in io.lettuce.core.cluster.pubsub.api.sync
Method parameters in io.lettuce.core.cluster.pubsub.api.sync with type arguments of type RedisClusterNode Modifier and Type Method Description PubSubNodeSelection<K,V>
RedisClusterPubSubCommands. nodes(Predicate<RedisClusterNode> predicate)
Select nodes by a predicate.default PubSubNodeSelection<K,V>
RedisClusterPubSubCommands. replicas(Predicate<RedisClusterNode> predicate)
Select all replicas.default PubSubNodeSelection<K,V>
RedisClusterPubSubCommands. slaves(Predicate<RedisClusterNode> predicate)
Deprecated.since 5.2, useRedisClusterPubSubCommands.replicas(Predicate)
-
Uses of RedisClusterNode in io.lettuce.core.cluster.topology
Methods in io.lettuce.core.cluster.topology that return types with arguments of type RedisClusterNode Modifier and Type Method Description static List<RedisClusterNode>
TopologyComparators. predefinedSort(Iterable<RedisClusterNode> clusterNodes, Iterable<RedisURI> fixedOrder)
Sort partitions by afixedOrder
and byRedisURI
.static List<RedisClusterNode>
TopologyComparators. sortByClientCount(Iterable<RedisClusterNode> clusterNodes)
Sort partitions by client count.static List<RedisClusterNode>
TopologyComparators. sortByLatency(Iterable<RedisClusterNode> clusterNodes)
Sort partitions by latency.static List<RedisClusterNode>
TopologyComparators. sortByUri(Iterable<RedisClusterNode> clusterNodes)
Sort partitions by RedisURI.Method parameters in io.lettuce.core.cluster.topology with type arguments of type RedisClusterNode Modifier and Type Method Description static List<RedisClusterNode>
TopologyComparators. predefinedSort(Iterable<RedisClusterNode> clusterNodes, Iterable<RedisURI> fixedOrder)
Sort partitions by afixedOrder
and byRedisURI
.static List<RedisClusterNode>
TopologyComparators. sortByClientCount(Iterable<RedisClusterNode> clusterNodes)
Sort partitions by client count.static List<RedisClusterNode>
TopologyComparators. sortByLatency(Iterable<RedisClusterNode> clusterNodes)
Sort partitions by latency.static List<RedisClusterNode>
TopologyComparators. sortByUri(Iterable<RedisClusterNode> clusterNodes)
Sort partitions by RedisURI.
-