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.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 the
CLUSTER NODES and CLUSTER SLAVES output. |
io.lettuce.core.cluster.models.slots |
Model and parser for the
CLUSTER 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.
|
Modifier and Type | Field and Description |
---|---|
static Predicate<RedisClusterNode> |
ClusterClientOptions.DEFAULT_NODE_FILTER |
Modifier and Type | Method and Description |
---|---|
Predicate<RedisClusterNode> |
ClusterClientOptions.getNodeFilter()
The
node filter to filter Redis Cluster nodes from
Partitions . |
Modifier and Type | Method and Description |
---|---|
protected <T> Map<String,CompletableFuture<T>> |
RedisAdvancedClusterAsyncCommandsImpl.executeOnNodes(Function<RedisClusterAsyncCommands<K,V>,RedisFuture<T>> function,
Function<RedisClusterNode,Boolean> filter)
Run a command on all available nodes that match
filter . |
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 match
filter . |
protected Mono<SocketAddress> |
RedisClusterClient.getSocketAddressSupplier(Supplier<Partitions> partitionsSupplier,
Function<Partitions,Collection<RedisClusterNode>> sortFunction)
Returns a
Supplier for connection points . |
ClusterClientOptions.Builder |
ClusterClientOptions.Builder.nodeFilter(Predicate<RedisClusterNode> nodeFilter)
Provide a
node filter to filter cluster nodes from
Partitions . |
AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommandsImpl.nodes(Predicate<RedisClusterNode> predicate) |
PubSubReactiveNodeSelection<K,V> |
RedisClusterPubSubReactiveCommandsImpl.nodes(Predicate<RedisClusterNode> predicate) |
PubSubAsyncNodeSelection<K,V> |
RedisClusterPubSubAsyncCommandsImpl.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) |
AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommandsImpl.readonly(Predicate<RedisClusterNode> predicate) |
Modifier and Type | Method and Description |
---|---|
RedisClusterNode |
NodeSelectionSupport.node(int index)
Get the
RedisClusterNode . |
Modifier and Type | Method and Description |
---|---|
Map<RedisClusterNode,API> |
NodeSelectionSupport.asMap() |
Modifier and Type | Method and Description |
---|---|
Map<RedisClusterNode,CompletableFuture<T>> |
AsyncExecutions.asMap() |
Collection<RedisClusterNode> |
AsyncExecutions.nodes() |
Modifier and Type | Method and Description |
---|---|
CompletionStage<T> |
AsyncExecutions.get(RedisClusterNode redisClusterNode) |
Modifier and Type | Method and 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 predicate
|
AsyncNodeSelection<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.
|
Modifier and Type | Method and Description |
---|---|
void |
RedisClusterPushListener.onPushMessage(RedisClusterNode node,
PushMessage message)
Handle a push message.
|
Modifier and Type | Method and Description |
---|---|
Collection<RedisClusterNode> |
ReactiveExecutions.nodes() |
Modifier and Type | Method and Description |
---|---|
Map<RedisClusterNode,T> |
Executions.asMap() |
Collection<RedisClusterNode> |
Executions.nodes() |
Modifier and Type | Method and Description |
---|---|
T |
Executions.get(RedisClusterNode redisClusterNode) |
Modifier and Type | Method and 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 predicate
|
NodeSelection<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, use
RedisAdvancedClusterCommands.replicas(Predicate) |
Modifier and Type | Method and 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 and Description |
---|
ClusterTopologyChangedEvent(List<RedisClusterNode> before,
List<RedisClusterNode> after)
Creates a new
ClusterTopologyChangedEvent . |
ClusterTopologyChangedEvent(List<RedisClusterNode> before,
List<RedisClusterNode> after)
Creates a new
ClusterTopologyChangedEvent . |
Modifier and Type | Method and Description |
---|---|
RedisClusterNode |
RedisClusterNode.clone()
Clone
this RedisClusterNode . |
RedisClusterNode |
Partitions.getMasterBySlot(int slot)
Retrieve a
master node by its slot number |
RedisClusterNode |
Partitions.getPartition(int index)
Returns the
RedisClusterNode at index . |
RedisClusterNode |
Partitions.getPartition(String host,
int port)
Retrieve a
RedisClusterNode by its hostname/port considering node aliases. |
RedisClusterNode |
Partitions.getPartitionByNodeId(String nodeId)
Retrieve a
RedisClusterNode by its node id. |
RedisClusterNode |
Partitions.getPartitionBySlot(int slot)
Retrieve a
RedisClusterNode by its slot number. |
static RedisClusterNode |
RedisClusterNode.of(String nodeId)
Create a new instance of
RedisClusterNode by passing the nodeId |
Modifier and Type | Method and Description |
---|---|
List<RedisClusterNode> |
Partitions.getPartitions()
Returns the internal
List of RedisClusterNode that holds the partition source. |
Iterator<RedisClusterNode> |
Partitions.iterator()
Returns an iterator over the
nodes in this Partitions from the read-view. |
Modifier and Type | Method and Description |
---|---|
boolean |
Partitions.add(RedisClusterNode redisClusterNode)
Adds the
RedisClusterNode to this Partitions . |
void |
Partitions.addPartition(RedisClusterNode partition)
Adds a partition without updating the read view/cache.
|
boolean |
RedisClusterNode.hasSameSlotsAs(RedisClusterNode other)
|
Modifier and Type | Method and Description |
---|---|
boolean |
Partitions.addAll(Collection<? extends RedisClusterNode> c)
Add all
nodes from the given collection and update the read-view/caches. |
void |
Partitions.reload(List<RedisClusterNode> partitions)
Update partitions and rebuild slot cache.
|
Constructor and Description |
---|
RedisClusterNode(RedisClusterNode redisClusterNode) |
Modifier and Type | Method and Description |
---|---|
RedisClusterNode |
ClusterSlotRange.getUpstream() |
Modifier and Type | Method and Description |
---|---|
List<RedisClusterNode> |
ClusterSlotRange.getReplicaNodes() |
List<RedisClusterNode> |
ClusterSlotRange.getSlaveNodes()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterSlotRange.setUpstream(RedisClusterNode upstream) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterSlotRange.setReplicaNodes(List<RedisClusterNode> replicaNodes) |
void |
ClusterSlotRange.setSlaveNodes(List<RedisClusterNode> slaveNodes)
Deprecated.
|
Constructor and Description |
---|
ClusterSlotRange(int from,
int to,
RedisClusterNode upstream,
List<RedisClusterNode> replicaNodes)
Constructs a
ClusterSlotRange |
Constructor and Description |
---|
ClusterSlotRange(int from,
int to,
RedisClusterNode upstream,
List<RedisClusterNode> replicaNodes)
Constructs a
ClusterSlotRange |
Modifier and Type | Method and Description |
---|---|
void |
RedisClusterPubSubListener.message(RedisClusterNode node,
K pattern,
K channel,
V message)
Message received from a pattern subscription.
|
void |
RedisClusterPubSubAdapter.message(RedisClusterNode node,
K pattern,
K channel,
V message) |
void |
RedisClusterPubSubListener.message(RedisClusterNode node,
K channel,
V message)
Message received from a channel subscription.
|
void |
RedisClusterPubSubAdapter.message(RedisClusterNode node,
K channel,
V message) |
void |
RedisClusterPubSubListener.psubscribed(RedisClusterNode node,
K pattern,
long count)
Subscribed to a pattern.
|
void |
RedisClusterPubSubAdapter.psubscribed(RedisClusterNode node,
K pattern,
long count) |
void |
RedisClusterPubSubListener.punsubscribed(RedisClusterNode node,
K pattern,
long count)
Unsubscribed from a pattern.
|
void |
RedisClusterPubSubAdapter.punsubscribed(RedisClusterNode node,
K pattern,
long count) |
void |
RedisClusterPubSubListener.subscribed(RedisClusterNode node,
K channel,
long count)
Subscribed to a channel.
|
void |
RedisClusterPubSubAdapter.subscribed(RedisClusterNode node,
K channel,
long count) |
void |
RedisClusterPubSubListener.unsubscribed(RedisClusterNode node,
K channel,
long count)
Unsubscribed from a channel.
|
void |
RedisClusterPubSubAdapter.unsubscribed(RedisClusterNode node,
K channel,
long count) |
Modifier and Type | Method and 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, use
RedisClusterPubSubAsyncCommands.replicas(Predicate) |
Modifier and Type | Method and 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, use
RedisClusterPubSubReactiveCommands.replicas() . |
Modifier and Type | Method and 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, use
RedisClusterPubSubCommands.replicas(Predicate) |
Modifier and Type | Method and Description |
---|---|
static List<RedisClusterNode> |
TopologyComparators.predefinedSort(Iterable<RedisClusterNode> clusterNodes,
Iterable<RedisURI> fixedOrder)
Sort partitions by a
fixedOrder and by RedisURI . |
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.
|
Modifier and Type | Method and Description |
---|---|
static List<RedisClusterNode> |
TopologyComparators.predefinedSort(Iterable<RedisClusterNode> clusterNodes,
Iterable<RedisURI> fixedOrder)
Sort partitions by a
fixedOrder and by RedisURI . |
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.
|
Copyright © 2024 lettuce.io. All rights reserved.