Package | Description |
---|---|
com.lambdaworks.redis.cluster |
Client for redis clusters
RedisClusterClient |
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 com.google.common.base.Supplier<SocketAddress> |
RedisClusterClient.getSocketAddressSupplier(com.google.common.base.Function<? extends Collection<RedisClusterNode>,Collection<RedisClusterNode>> sortFunction)
Returns a
Supplier for connection points . |
protected com.google.common.base.Supplier<SocketAddress> |
RedisClusterClient.getSocketAddressSupplier(com.google.common.base.Function<? extends Collection<RedisClusterNode>,Collection<RedisClusterNode>> sortFunction)
Returns a
Supplier for connection points . |
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. |
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.