Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with
the various Redis 'drivers'/libraries.
|
org.springframework.data.redis.connection.convert | |
org.springframework.data.redis.connection.jedis |
Connection package for Jedis library.
|
org.springframework.data.redis.connection.lettuce |
Connection package for Lettuce Redis client.
|
org.springframework.data.redis.core |
Core package for integrating Redis with Spring concepts.
|
Modifier and Type | Method and Description |
---|---|
RedisClusterNode |
RedisClusterNode.RedisClusterNodeBuilder.build() |
RedisClusterNode |
RedisClusterCommands.clusterGetNodeForKey(byte[] key)
Find the
RedisClusterNode serving given key. |
RedisClusterNode |
RedisClusterCommands.clusterGetNodeForSlot(int slot)
Find the
RedisClusterNode serving given slot. |
RedisClusterNode |
ClusterTopology.getKeyServingMasterNode(byte[] key)
Get the
RedisClusterNode that is the current master serving the given key. |
RedisClusterNode |
ClusterCommandExecutor.NodeResult.getNode()
Get the
RedisClusterNode the command was executed on. |
RedisClusterNode |
ClusterTopology.lookup(RedisClusterNode node)
|
RedisClusterNode |
ClusterTopology.lookup(String nodeId)
Get the
RedisClusterNode matching given nodeId. |
RedisClusterNode |
ClusterTopology.lookup(String host,
int port)
Get the
RedisClusterNode matching given host and port. |
Modifier and Type | Method and Description |
---|---|
Map<RedisClusterNode,Collection<RedisClusterNode>> |
RedisClusterCommands.clusterGetMasterSlaveMap()
Retrieve information about masters and their connected slaves.
|
Map<RedisClusterNode,Collection<RedisClusterNode>> |
RedisClusterCommands.clusterGetMasterSlaveMap()
Retrieve information about masters and their connected slaves.
|
Iterable<RedisClusterNode> |
RedisClusterCommands.clusterGetNodes()
Retrieve cluster node information such as id, host, port and slots.
|
Collection<RedisClusterNode> |
RedisClusterCommands.clusterGetSlaves(RedisClusterNode master)
Retrieve information about connected slaves for given master node.
|
Set<RedisClusterNode> |
ClusterTopology.getActiveMasterNodes()
Get all master nodes in cluster where
link-state is connected and flags does not contain
fail or fail?. |
Set<RedisClusterNode> |
ClusterTopology.getActiveNodes()
Get all nodes (master and slave) in cluster where
link-state is connected and flags does
not contain fail or fail?. |
Set<RedisClusterNode> |
ClusterTopology.getKeyServingNodes(byte[] key) |
Set<RedisClusterNode> |
ClusterTopology.getMasterNodes()
Get all master nodes in cluster.
|
Set<RedisClusterNode> |
ClusterTopology.getNodes()
Get all
RedisClusterNode s. |
Set<RedisClusterNode> |
ClusterTopology.getSlotServingNodes(int slot)
Get the
RedisClusterNode s (master and slave) serving s specific slot. |
Modifier and Type | Method and Description |
---|---|
void |
RedisClusterConnection.bgReWriteAof(RedisClusterNode node) |
void |
RedisClusterConnection.bgSave(RedisClusterNode node) |
void |
RedisClusterCommands.clusterAddSlots(RedisClusterNode node,
int... slots)
Assign slots to given
RedisClusterNode . |
void |
RedisClusterCommands.clusterAddSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Assign
RedisClusterNode.SlotRange.getSlotsArray() to given RedisClusterNode . |
void |
RedisClusterCommands.clusterDeleteSlots(RedisClusterNode node,
int... slots)
Remove slots from
RedisClusterNode . |
void |
RedisClusterCommands.clusterDeleteSlotsInRange(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Removes
RedisClusterNode.SlotRange.getSlotsArray() from given RedisClusterNode . |
void |
RedisClusterCommands.clusterForget(RedisClusterNode node)
Remove given node from cluster.
|
Collection<RedisClusterNode> |
RedisClusterCommands.clusterGetSlaves(RedisClusterNode master)
Retrieve information about connected slaves for given master node.
|
void |
RedisClusterCommands.clusterMeet(RedisClusterNode node)
Add given node to cluster.
|
void |
RedisClusterCommands.clusterReplicate(RedisClusterNode master,
RedisClusterNode slave)
Assign a slave to given master.
|
void |
RedisClusterCommands.clusterSetSlot(RedisClusterNode node,
int slot,
RedisClusterCommands.AddSlots mode) |
Long |
RedisClusterConnection.dbSize(RedisClusterNode node) |
<S,T> ClusterCommandExecutor.NodeResult<T> |
ClusterCommandExecutor.executeCommandOnSingleNode(ClusterCommandExecutor.ClusterCommandCallback<S,T> cmd,
RedisClusterNode node)
|
void |
RedisClusterConnection.flushAll(RedisClusterNode node) |
void |
RedisClusterConnection.flushDb(RedisClusterNode node) |
List<RedisClientInfo> |
RedisClusterConnection.getClientList(RedisClusterNode node) |
List<String> |
RedisClusterConnection.getConfig(RedisClusterNode node,
String pattern) |
<S> S |
ClusterNodeResourceProvider.getResourceForSpecificNode(RedisClusterNode node)
Get the client resource for the given node.
|
Properties |
RedisClusterConnection.info(RedisClusterNode node) |
Properties |
RedisClusterConnection.info(RedisClusterNode node,
String section) |
Set<byte[]> |
RedisClusterConnection.keys(RedisClusterNode node,
byte[] pattern) |
reactor.core.publisher.Mono<List<ByteBuffer>> |
ReactiveClusterKeyCommands.keys(RedisClusterNode node,
ByteBuffer pattern)
Retrieve all keys for a given pattern from
RedisNode . |
Long |
RedisClusterConnection.lastSave(RedisClusterNode node) |
RedisClusterNode |
ClusterTopology.lookup(RedisClusterNode node)
|
String |
RedisClusterConnection.ping(RedisClusterNode node) |
byte[] |
RedisClusterConnection.randomKey(RedisClusterNode node) |
reactor.core.publisher.Mono<ByteBuffer> |
ReactiveClusterKeyCommands.randomKey(RedisClusterNode node)
Retrieve a random key from
RedisNode . |
void |
RedisClusterConnection.resetConfigStats(RedisClusterNode node) |
void |
ClusterNodeResourceProvider.returnResourceForSpecificNode(RedisClusterNode node,
Object resource)
Return the resource object for the given node.
|
void |
RedisClusterConnection.save(RedisClusterNode node) |
void |
RedisClusterConnection.setConfig(RedisClusterNode node,
String param,
String value) |
void |
RedisClusterConnection.shutdown(RedisClusterNode node) |
Long |
RedisClusterConnection.time(RedisClusterNode node) |
Modifier and Type | Method and Description |
---|---|
<S,T> ClusterCommandExecutor.MulitNodeResult<T> |
ClusterCommandExecutor.executeCommandAsyncOnNodes(ClusterCommandExecutor.ClusterCommandCallback<S,T> callback,
Iterable<RedisClusterNode> nodes) |
Constructor and Description |
---|
NodeResult(RedisClusterNode node,
T value)
Create new
ClusterCommandExecutor.NodeResult . |
NodeResult(RedisClusterNode node,
T value,
byte[] key)
Create new
ClusterCommandExecutor.NodeResult . |
Constructor and Description |
---|
ClusterTopology(Set<RedisClusterNode> nodes)
Creates new instance of
ClusterTopology . |
Modifier and Type | Method and Description |
---|---|
protected static RedisClusterNode |
Converters.toClusterNode(String clusterNodesLine)
Converts the result of a single line of
CLUSTER NODES into a RedisClusterNode . |
Modifier and Type | Method and Description |
---|---|
static Set<RedisClusterNode> |
Converters.toSetOfRedisClusterNodes(Collection<String> lines)
Converts lines from the result of
CLUSTER NODES into RedisClusterNode s. |
static Set<RedisClusterNode> |
Converters.toSetOfRedisClusterNodes(String clusterNodes)
Converts the result of
CLUSTER NODES into RedisClusterNode s. |
Modifier and Type | Method and Description |
---|---|
RedisClusterNode |
JedisClusterConnection.clusterGetNodeForKey(byte[] key) |
RedisClusterNode |
JedisClusterConnection.clusterGetNodeForSlot(int slot) |
static RedisClusterNode |
JedisConverters.toNode(Object source) |
Modifier and Type | Method and Description |
---|---|
Map<RedisClusterNode,Collection<RedisClusterNode>> |
JedisClusterConnection.clusterGetMasterSlaveMap() |
Map<RedisClusterNode,Collection<RedisClusterNode>> |
JedisClusterConnection.clusterGetMasterSlaveMap() |
Set<RedisClusterNode> |
JedisClusterConnection.clusterGetNodes() |
Set<RedisClusterNode> |
JedisClusterConnection.clusterGetSlaves(RedisClusterNode master) |
Modifier and Type | Method and Description |
---|---|
void |
JedisClusterConnection.bgReWriteAof(RedisClusterNode node) |
void |
JedisClusterConnection.bgSave(RedisClusterNode node) |
void |
JedisClusterConnection.clusterAddSlots(RedisClusterNode node,
int... slots) |
void |
JedisClusterConnection.clusterAddSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range) |
void |
JedisClusterConnection.clusterDeleteSlots(RedisClusterNode node,
int... slots) |
void |
JedisClusterConnection.clusterDeleteSlotsInRange(RedisClusterNode node,
RedisClusterNode.SlotRange range) |
void |
JedisClusterConnection.clusterForget(RedisClusterNode node) |
Set<RedisClusterNode> |
JedisClusterConnection.clusterGetSlaves(RedisClusterNode master) |
void |
JedisClusterConnection.clusterMeet(RedisClusterNode node) |
void |
JedisClusterConnection.clusterReplicate(RedisClusterNode master,
RedisClusterNode slave) |
void |
JedisClusterConnection.clusterSetSlot(RedisClusterNode node,
int slot,
RedisClusterCommands.AddSlots mode) |
Long |
JedisClusterConnection.dbSize(RedisClusterNode node) |
void |
JedisClusterConnection.flushAll(RedisClusterNode node) |
void |
JedisClusterConnection.flushDb(RedisClusterNode node) |
List<RedisClientInfo> |
JedisClusterConnection.getClientList(RedisClusterNode node) |
List<String> |
JedisClusterConnection.getConfig(RedisClusterNode node,
String pattern) |
Properties |
JedisClusterConnection.info(RedisClusterNode node) |
Properties |
JedisClusterConnection.info(RedisClusterNode node,
String section) |
Set<byte[]> |
JedisClusterConnection.keys(RedisClusterNode node,
byte[] pattern) |
Long |
JedisClusterConnection.lastSave(RedisClusterNode node) |
String |
JedisClusterConnection.ping(RedisClusterNode node) |
byte[] |
JedisClusterConnection.randomKey(RedisClusterNode node) |
void |
JedisClusterConnection.resetConfigStats(RedisClusterNode node) |
void |
JedisClusterConnection.save(RedisClusterNode node) |
void |
JedisClusterConnection.setConfig(RedisClusterNode node,
String param,
String value) |
void |
JedisClusterConnection.shutdown(RedisClusterNode node) |
Long |
JedisClusterConnection.time(RedisClusterNode node) |
Modifier and Type | Method and Description |
---|---|
RedisClusterNode |
LettuceClusterConnection.clusterGetNodeForKey(byte[] key) |
RedisClusterNode |
LettuceClusterConnection.clusterGetNodeForSlot(int slot) |
static RedisClusterNode |
LettuceConverters.toRedisClusterNode(com.lambdaworks.redis.cluster.models.partitions.RedisClusterNode source) |
Modifier and Type | Method and Description |
---|---|
Map<RedisClusterNode,Collection<RedisClusterNode>> |
LettuceClusterConnection.clusterGetMasterSlaveMap() |
Map<RedisClusterNode,Collection<RedisClusterNode>> |
LettuceClusterConnection.clusterGetMasterSlaveMap() |
List<RedisClusterNode> |
LettuceClusterConnection.clusterGetNodes() |
Set<RedisClusterNode> |
LettuceClusterConnection.clusterGetSlaves(RedisClusterNode master) |
static List<RedisClusterNode> |
LettuceConverters.partitionsToClusterNodes(com.lambdaworks.redis.cluster.models.partitions.Partitions partitions) |
Modifier and Type | Method and Description |
---|---|
void |
LettuceClusterConnection.bgReWriteAof(RedisClusterNode node) |
void |
LettuceClusterConnection.bgSave(RedisClusterNode node) |
void |
LettuceClusterConnection.clusterAddSlots(RedisClusterNode node,
int... slots) |
void |
LettuceClusterConnection.clusterAddSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range) |
void |
LettuceClusterConnection.clusterDeleteSlots(RedisClusterNode node,
int... slots) |
void |
LettuceClusterConnection.clusterDeleteSlotsInRange(RedisClusterNode node,
RedisClusterNode.SlotRange range) |
void |
LettuceClusterConnection.clusterForget(RedisClusterNode node) |
Set<RedisClusterNode> |
LettuceClusterConnection.clusterGetSlaves(RedisClusterNode master) |
void |
LettuceClusterConnection.clusterMeet(RedisClusterNode node) |
void |
LettuceClusterConnection.clusterReplicate(RedisClusterNode master,
RedisClusterNode slave) |
void |
LettuceClusterConnection.clusterSetSlot(RedisClusterNode node,
int slot,
RedisClusterCommands.AddSlots mode) |
Long |
LettuceClusterConnection.dbSize(RedisClusterNode node) |
void |
LettuceClusterConnection.flushAll(RedisClusterNode node) |
void |
LettuceClusterConnection.flushDb(RedisClusterNode node) |
List<RedisClientInfo> |
LettuceClusterConnection.getClientList(RedisClusterNode node) |
List<String> |
LettuceClusterConnection.getConfig(RedisClusterNode node,
String pattern) |
Properties |
LettuceClusterConnection.info(RedisClusterNode node) |
Properties |
LettuceClusterConnection.info(RedisClusterNode node,
String section) |
Set<byte[]> |
LettuceClusterConnection.keys(RedisClusterNode node,
byte[] pattern) |
reactor.core.publisher.Mono<List<ByteBuffer>> |
LettuceReactiveClusterKeyCommands.keys(RedisClusterNode node,
ByteBuffer pattern) |
Long |
LettuceClusterConnection.lastSave(RedisClusterNode node) |
String |
LettuceClusterConnection.ping(RedisClusterNode node) |
reactor.core.publisher.Mono<ByteBuffer> |
LettuceReactiveClusterKeyCommands.randomKey(RedisClusterNode node) |
byte[] |
LettuceClusterConnection.randomKey(RedisClusterNode node) |
void |
LettuceClusterConnection.resetConfigStats(RedisClusterNode node) |
void |
LettuceClusterConnection.save(RedisClusterNode node) |
void |
LettuceClusterConnection.setConfig(RedisClusterNode node,
String param,
String value) |
void |
LettuceClusterConnection.shutdown(RedisClusterNode node) |
Long |
LettuceClusterConnection.time(RedisClusterNode node) |
Modifier and Type | Method and Description |
---|---|
Collection<RedisClusterNode> |
DefaultClusterOperations.getSlaves(RedisClusterNode node) |
Collection<RedisClusterNode> |
ClusterOperations.getSlaves(RedisClusterNode node) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultClusterOperations.addSlots(RedisClusterNode node,
int... slots) |
void |
ClusterOperations.addSlots(RedisClusterNode node,
int... slots)
Add slots to given node;
|
void |
DefaultClusterOperations.addSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range) |
void |
ClusterOperations.addSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Add slots in
RedisClusterNode.SlotRange to given node. |
void |
DefaultClusterOperations.bgReWriteAof(RedisClusterNode node) |
void |
ClusterOperations.bgReWriteAof(RedisClusterNode node)
Start an Append Only File rewrite process on given node.
|
void |
DefaultClusterOperations.bgSave(RedisClusterNode node) |
void |
ClusterOperations.bgSave(RedisClusterNode node)
Start background saving of db on given node.
|
void |
DefaultClusterOperations.flushDb(RedisClusterNode node) |
void |
ClusterOperations.flushDb(RedisClusterNode node)
Flush db on node.
|
void |
DefaultClusterOperations.forget(RedisClusterNode node) |
void |
ClusterOperations.forget(RedisClusterNode node)
Remove the node from the cluster.
|
Collection<RedisClusterNode> |
DefaultClusterOperations.getSlaves(RedisClusterNode node) |
Collection<RedisClusterNode> |
ClusterOperations.getSlaves(RedisClusterNode node) |
Set<K> |
DefaultClusterOperations.keys(RedisClusterNode node,
K pattern) |
Set<K> |
ClusterOperations.keys(RedisClusterNode node,
K pattern)
Get all keys located at given node.
|
void |
DefaultClusterOperations.meet(RedisClusterNode node) |
void |
ClusterOperations.meet(RedisClusterNode node)
Add the node to cluster.
|
String |
DefaultClusterOperations.ping(RedisClusterNode node) |
String |
ClusterOperations.ping(RedisClusterNode node)
Ping the given node;
|
K |
DefaultClusterOperations.randomKey(RedisClusterNode node) |
K |
ClusterOperations.randomKey(RedisClusterNode node)
Get a random key from the range served by the given node.
|
void |
DefaultClusterOperations.reshard(RedisClusterNode source,
int slot,
RedisClusterNode target) |
void |
ClusterOperations.reshard(RedisClusterNode source,
int slot,
RedisClusterNode target)
Move slot assignment from one source to target node and copy keys associated with the slot.
|
void |
DefaultClusterOperations.save(RedisClusterNode node) |
void |
ClusterOperations.save(RedisClusterNode node)
Synchronous save current db snapshot on server.
|
void |
DefaultClusterOperations.shutdown(RedisClusterNode node) |
void |
ClusterOperations.shutdown(RedisClusterNode node)
Shutdown given node.
|
Copyright © 2011-2016–2016 Pivotal Software, Inc.. All rights reserved.