Package | Description |
---|---|
com.lambdaworks.redis.cluster |
Client for redis clusters
RedisClusterClient . |
com.lambdaworks.redis.cluster.api |
Redis Cluster connection API.
|
com.lambdaworks.redis.cluster.api.async |
Redis Cluster API for asynchronous executed commands.
|
com.lambdaworks.redis.cluster.api.sync |
Redis Cluster API for synchronous executed commands.
|
com.lambdaworks.redis.cluster.event | |
com.lambdaworks.redis.cluster.models.partitions |
Model and parser for the
CLUSTER NODES and CLUSTER SLAVES output. |
com.lambdaworks.redis.cluster.models.slots |
Model and parser for the
CLUSTER SLOTS output. |
Modifier and Type | Method and Description |
---|---|
protected <T> Map<String,RedisFuture<T>> |
RedisAdvancedClusterAsyncCommandsImpl.executeOnNodes(java.util.function.Function<RedisClusterAsyncCommands<K,V>,RedisFuture<T>> function,
java.util.function.Function<RedisClusterNode,Boolean> filter)
Run a command on all available nodes that match
filter . |
protected <T> Map<String,Observable<T>> |
RedisAdvancedClusterReactiveCommandsImpl.executeOnNodes(java.util.function.Function<RedisClusterReactiveCommands<K,V>,Observable<T>> function,
java.util.function.Function<RedisClusterNode,Boolean> filter)
Run a command on all available nodes that match
filter . |
AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommandsImpl.nodes(java.util.function.Predicate<RedisClusterNode> predicate) |
AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommandsImpl.nodes(java.util.function.Predicate<RedisClusterNode> predicate,
boolean dynamic) |
protected AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommandsImpl.nodes(java.util.function.Predicate<RedisClusterNode> predicate,
ClusterConnectionProvider.Intent intent,
boolean dynamic) |
AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommandsImpl.readonly(java.util.function.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,CompletionStage<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(java.util.function.Predicate<RedisClusterNode> predicate)
Select nodes by a predicate and keeps a static selection.
|
AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommands.nodes(java.util.function.Predicate<RedisClusterNode> predicate,
boolean dynamic)
Select nodes by a predicate
|
AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommands.readonly(java.util.function.Predicate<RedisClusterNode> predicate)
Select slave nodes by a predicate and keeps a static selection.
|
default AsyncNodeSelection<K,V> |
RedisAdvancedClusterAsyncCommands.slaves(java.util.function.Predicate<RedisClusterNode> predicate)
Select all slaves.
|
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(java.util.function.Predicate<RedisClusterNode> predicate)
Select nodes by a predicate and keeps a static selection.
|
NodeSelection<K,V> |
RedisAdvancedClusterCommands.nodes(java.util.function.Predicate<RedisClusterNode> predicate,
boolean dynamic)
Select nodes by a predicate
|
NodeSelection<K,V> |
RedisAdvancedClusterCommands.readonly(java.util.function.Predicate<RedisClusterNode> predicate)
Select slave nodes by a predicate and keeps a static selection.
|
default NodeSelection<K,V> |
RedisAdvancedClusterCommands.slaves(java.util.function.Predicate<RedisClusterNode> predicate)
Select all slaves.
|
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 |
Partitions.getPartition(int index) |
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() |
Iterator<RedisClusterNode> |
Partitions.iterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
Partitions.add(RedisClusterNode redisClusterNode) |
void |
Partitions.addPartition(RedisClusterNode partition) |
Modifier and Type | Method and Description |
---|---|
boolean |
Partitions.addAll(Collection<? extends RedisClusterNode> c) |
void |
Partitions.reload(List<RedisClusterNode> partitions)
Update partitions and rebuild slot cache.
|
Modifier and Type | Method and Description |
---|---|
RedisClusterNode |
ClusterSlotRange.getMasterNode() |
Modifier and Type | Method and Description |
---|---|
List<RedisClusterNode> |
ClusterSlotRange.getSlaveNodes() |
Modifier and Type | Method and Description |
---|---|
void |
ClusterSlotRange.setMasterNode(RedisClusterNode masterNode) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterSlotRange.setSlaveNodes(List<RedisClusterNode> slaveNodes) |
Constructor and Description |
---|
ClusterSlotRange(int from,
int to,
RedisClusterNode masterNode,
List<RedisClusterNode> slaveNodes)
Constructs a
ClusterSlotRange |
Constructor and Description |
---|
ClusterSlotRange(int from,
int to,
RedisClusterNode masterNode,
List<RedisClusterNode> slaveNodes)
Constructs a
ClusterSlotRange |
Copyright © 2016. All rights reserved.