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 |
Redis specific converters used for sending data and parsing responses.
|
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 |
---|---|
reactor.core.publisher.Mono<Map<RedisClusterNode,Collection<RedisClusterNode>>> |
ReactiveClusterCommands.clusterGetMasterSlaveMap()
Retrieve information about masters and their connected slaves.
|
reactor.core.publisher.Mono<Map<RedisClusterNode,Collection<RedisClusterNode>>> |
ReactiveClusterCommands.clusterGetMasterSlaveMap()
Retrieve information about masters and their connected slaves.
|
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.
|
reactor.core.publisher.Mono<RedisClusterNode> |
ReactiveClusterCommands.clusterGetNodeForKey(ByteBuffer key)
Find the
RedisClusterNode serving given key. |
reactor.core.publisher.Mono<RedisClusterNode> |
ReactiveClusterCommands.clusterGetNodeForSlot(int slot)
Find the
RedisClusterNode serving given slot. |
reactor.core.publisher.Flux<RedisClusterNode> |
ReactiveClusterCommands.clusterGetNodes()
Retrieve cluster node information such as id, host, port and slots.
|
Iterable<RedisClusterNode> |
RedisClusterCommands.clusterGetNodes()
Retrieve cluster node information such as id, host, port and slots.
|
reactor.core.publisher.Flux<RedisClusterNode> |
ReactiveClusterCommands.clusterGetSlaves(RedisClusterNode master)
Retrieve information about connected slaves for given master node.
|
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 |
RedisClusterServerCommands.bgReWriteAof(RedisClusterNode node) |
reactor.core.publisher.Mono<String> |
ReactiveClusterServerCommands.bgReWriteAof(RedisClusterNode node)
Start an Append Only File rewrite process on the specific server.
|
default void |
DefaultedRedisClusterConnection.bgReWriteAof(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
void |
RedisClusterServerCommands.bgSave(RedisClusterNode node) |
reactor.core.publisher.Mono<String> |
ReactiveClusterServerCommands.bgSave(RedisClusterNode node)
Start background saving of db on server.
|
default void |
DefaultedRedisClusterConnection.bgSave(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
reactor.core.publisher.Mono<Void> |
ReactiveClusterCommands.clusterAddSlots(RedisClusterNode node,
int... slots)
Assign slots to given
RedisClusterNode . |
void |
RedisClusterCommands.clusterAddSlots(RedisClusterNode node,
int... slots)
Assign slots to given
RedisClusterNode . |
reactor.core.publisher.Mono<Void> |
ReactiveClusterCommands.clusterAddSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Assign
RedisClusterNode.SlotRange.getSlotsArray() to given RedisClusterNode . |
void |
RedisClusterCommands.clusterAddSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Assign
RedisClusterNode.SlotRange.getSlotsArray() to given RedisClusterNode . |
reactor.core.publisher.Mono<Void> |
ReactiveClusterCommands.clusterDeleteSlots(RedisClusterNode node,
int... slots)
Remove slots from
RedisClusterNode . |
void |
RedisClusterCommands.clusterDeleteSlots(RedisClusterNode node,
int... slots)
Remove slots from
RedisClusterNode . |
reactor.core.publisher.Mono<Void> |
ReactiveClusterCommands.clusterDeleteSlotsInRange(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Removes
RedisClusterNode.SlotRange.getSlotsArray() from given RedisClusterNode . |
void |
RedisClusterCommands.clusterDeleteSlotsInRange(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Removes
RedisClusterNode.SlotRange.getSlotsArray() from given RedisClusterNode . |
reactor.core.publisher.Mono<Void> |
ReactiveClusterCommands.clusterForget(RedisClusterNode node)
Remove given node from cluster.
|
void |
RedisClusterCommands.clusterForget(RedisClusterNode node)
Remove given node from cluster.
|
reactor.core.publisher.Flux<RedisClusterNode> |
ReactiveClusterCommands.clusterGetSlaves(RedisClusterNode master)
Retrieve information about connected slaves for given master node.
|
Collection<RedisClusterNode> |
RedisClusterCommands.clusterGetSlaves(RedisClusterNode master)
Retrieve information about connected slaves for given master node.
|
reactor.core.publisher.Mono<Void> |
ReactiveClusterCommands.clusterMeet(RedisClusterNode node)
Add given node to cluster.
|
void |
RedisClusterCommands.clusterMeet(RedisClusterNode node)
Add given node to cluster.
|
reactor.core.publisher.Mono<Void> |
ReactiveClusterCommands.clusterReplicate(RedisClusterNode master,
RedisClusterNode replica)
Assign a slave to given master.
|
void |
RedisClusterCommands.clusterReplicate(RedisClusterNode master,
RedisClusterNode replica)
Assign a slave to given master.
|
reactor.core.publisher.Mono<Void> |
ReactiveClusterCommands.clusterSetSlot(RedisClusterNode node,
int slot,
ReactiveClusterCommands.AddSlots mode) |
void |
RedisClusterCommands.clusterSetSlot(RedisClusterNode node,
int slot,
RedisClusterCommands.AddSlots mode) |
Long |
RedisClusterServerCommands.dbSize(RedisClusterNode node) |
reactor.core.publisher.Mono<Long> |
ReactiveClusterServerCommands.dbSize(RedisClusterNode node)
Get the total number of available keys in currently selected database.
|
default Long |
DefaultedRedisClusterConnection.dbSize(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
<S,T> ClusterCommandExecutor.NodeResult<T> |
ClusterCommandExecutor.executeCommandOnSingleNode(ClusterCommandExecutor.ClusterCommandCallback<S,T> cmd,
RedisClusterNode node)
|
void |
RedisClusterServerCommands.flushAll(RedisClusterNode node) |
reactor.core.publisher.Mono<String> |
ReactiveClusterServerCommands.flushAll(RedisClusterNode node)
Delete all all keys from all databases.
|
default void |
DefaultedRedisClusterConnection.flushAll(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
void |
RedisClusterServerCommands.flushDb(RedisClusterNode node) |
reactor.core.publisher.Mono<String> |
ReactiveClusterServerCommands.flushDb(RedisClusterNode node)
Delete all keys of the currently selected database.
|
default void |
DefaultedRedisClusterConnection.flushDb(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
List<RedisClientInfo> |
RedisClusterServerCommands.getClientList(RedisClusterNode node) |
reactor.core.publisher.Flux<RedisClientInfo> |
ReactiveClusterServerCommands.getClientList(RedisClusterNode node)
Request information and statistics about connected clients.
|
default List<RedisClientInfo> |
DefaultedRedisClusterConnection.getClientList(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
Properties |
RedisClusterServerCommands.getConfig(RedisClusterNode node,
String pattern) |
reactor.core.publisher.Mono<Properties> |
ReactiveClusterServerCommands.getConfig(RedisClusterNode node,
String pattern)
Load configuration parameters for given
pattern from server. |
default Properties |
DefaultedRedisClusterConnection.getConfig(RedisClusterNode node,
String pattern)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
<S> S |
ClusterNodeResourceProvider.getResourceForSpecificNode(RedisClusterNode node)
Get the client resource for the given node.
|
Properties |
RedisClusterServerCommands.info(RedisClusterNode node) |
reactor.core.publisher.Mono<Properties> |
ReactiveClusterServerCommands.info(RedisClusterNode node)
Load default server information like
memory
cpu utilization
replication
|
default Properties |
DefaultedRedisClusterConnection.info(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
Properties |
RedisClusterServerCommands.info(RedisClusterNode node,
String section) |
reactor.core.publisher.Mono<Properties> |
ReactiveClusterServerCommands.info(RedisClusterNode node,
String section)
Load server information for given
selection . |
default Properties |
DefaultedRedisClusterConnection.info(RedisClusterNode node,
String section)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
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 |
RedisClusterServerCommands.lastSave(RedisClusterNode node) |
reactor.core.publisher.Mono<Long> |
ReactiveClusterServerCommands.lastSave(RedisClusterNode node)
Get time unix timestamp of last successful
ReactiveServerCommands.bgSave() operation in seconds. |
default Long |
DefaultedRedisClusterConnection.lastSave(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
RedisClusterNode |
ClusterTopology.lookup(RedisClusterNode node)
|
reactor.core.publisher.Mono<String> |
ReactiveRedisClusterConnection.ping(RedisClusterNode node)
Test the connection to a specific Redis cluster node.
|
String |
RedisClusterConnection.ping(RedisClusterNode node) |
reactor.core.publisher.Mono<ByteBuffer> |
ReactiveClusterKeyCommands.randomKey(RedisClusterNode node)
Retrieve a random key from
RedisNode . |
byte[] |
RedisClusterConnection.randomKey(RedisClusterNode node) |
void |
RedisClusterServerCommands.resetConfigStats(RedisClusterNode node) |
reactor.core.publisher.Mono<String> |
ReactiveClusterServerCommands.resetConfigStats(RedisClusterNode node)
Reset statistic counters on server.
|
default void |
DefaultedRedisClusterConnection.resetConfigStats(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
void |
ClusterNodeResourceProvider.returnResourceForSpecificNode(RedisClusterNode node,
Object resource)
Return the resource object for the given node.
|
void |
RedisClusterServerCommands.save(RedisClusterNode node) |
reactor.core.publisher.Mono<String> |
ReactiveClusterServerCommands.save(RedisClusterNode node)
Synchronous save current db snapshot on server.
|
default void |
DefaultedRedisClusterConnection.save(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
Cursor<byte[]> |
RedisClusterConnection.scan(RedisClusterNode node,
ScanOptions options)
Use a
Cursor to iterate over keys. |
void |
RedisClusterServerCommands.setConfig(RedisClusterNode node,
String param,
String value) |
reactor.core.publisher.Mono<String> |
ReactiveClusterServerCommands.setConfig(RedisClusterNode node,
String param,
String value)
Set server configuration for
param to value . |
default void |
DefaultedRedisClusterConnection.setConfig(RedisClusterNode node,
String param,
String value)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
void |
RedisClusterServerCommands.shutdown(RedisClusterNode node) |
default void |
DefaultedRedisClusterConnection.shutdown(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
Long |
RedisClusterServerCommands.time(RedisClusterNode node) |
reactor.core.publisher.Mono<Long> |
ReactiveClusterServerCommands.time(RedisClusterNode node)
Request server timestamp using
TIME command. |
default Long |
DefaultedRedisClusterConnection.time(RedisClusterNode node)
Deprecated.
in favor of
RedisConnection.serverCommands() . |
Modifier and Type | Method and Description |
---|---|
<S,T> ClusterCommandExecutor.MultiNodeResult<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.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 replica) |
void |
JedisClusterConnection.clusterSetSlot(RedisClusterNode node,
int slot,
RedisClusterCommands.AddSlots mode) |
Set<byte[]> |
JedisClusterConnection.keys(RedisClusterNode node,
byte[] pattern) |
String |
JedisClusterConnection.ping(RedisClusterNode node) |
byte[] |
JedisClusterConnection.randomKey(RedisClusterNode node) |
Cursor<byte[]> |
JedisClusterConnection.scan(RedisClusterNode node,
ScanOptions options) |
Modifier and Type | Method and Description |
---|---|
RedisClusterNode |
LettuceClusterConnection.clusterGetNodeForKey(byte[] key) |
RedisClusterNode |
LettuceClusterConnection.clusterGetNodeForSlot(int slot) |
static RedisClusterNode |
LettuceConverters.toRedisClusterNode(io.lettuce.core.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(io.lettuce.core.cluster.models.partitions.Partitions partitions) |
Modifier and Type | Method and Description |
---|---|
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 replica) |
void |
LettuceClusterConnection.clusterSetSlot(RedisClusterNode node,
int slot,
RedisClusterCommands.AddSlots mode) |
Set<byte[]> |
LettuceClusterConnection.keys(RedisClusterNode node,
byte[] pattern) |
String |
LettuceClusterConnection.ping(RedisClusterNode node) |
byte[] |
LettuceClusterConnection.randomKey(RedisClusterNode node) |
Cursor<byte[]> |
LettuceClusterConnection.scan(RedisClusterNode node,
ScanOptions options) |
Modifier and Type | Method and Description |
---|---|
Collection<RedisClusterNode> |
ClusterOperations.getSlaves(RedisClusterNode node) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterOperations.addSlots(RedisClusterNode node,
int... slots)
Add slots to given node;
|
void |
ClusterOperations.addSlots(RedisClusterNode node,
RedisClusterNode.SlotRange range)
Add slots in
RedisClusterNode.SlotRange to given node. |
void |
ClusterOperations.bgReWriteAof(RedisClusterNode node)
Start an Append Only File rewrite process on given node.
|
void |
ClusterOperations.bgSave(RedisClusterNode node)
Start background saving of db on given node.
|
void |
ClusterOperations.flushDb(RedisClusterNode node)
Flush db on node.
|
void |
ClusterOperations.forget(RedisClusterNode node)
Remove the node from the cluster.
|
Collection<RedisClusterNode> |
ClusterOperations.getSlaves(RedisClusterNode node) |
Set<K> |
ClusterOperations.keys(RedisClusterNode node,
K pattern)
Get all keys located at given node.
|
void |
ClusterOperations.meet(RedisClusterNode node)
Add the node to cluster.
|
String |
ClusterOperations.ping(RedisClusterNode node)
Ping the given node;
|
K |
ClusterOperations.randomKey(RedisClusterNode node)
Get a random key from the range served by the given node.
|
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 |
ClusterOperations.save(RedisClusterNode node)
Synchronous save current db snapshot on server.
|
void |
ClusterOperations.shutdown(RedisClusterNode node)
Shutdown given node.
|
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.