Uses of Class
org.springframework.data.redis.connection.RedisClusterNode
Package
Description
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
Redis specific converters used for sending data and parsing responses.
Connection package for Jedis library.
Connection package for Lettuce Redis client.
Core package for integrating Redis with Spring concepts.
-
Uses of RedisClusterNode in org.springframework.data.redis.connection
Modifier and TypeMethodDescriptionRedisClusterNode.RedisClusterNodeBuilder.build()
RedisClusterCommands.clusterGetNodeForKey
(byte[] key) Find theRedisClusterNode
serving given key.RedisClusterCommands.clusterGetNodeForSlot
(int slot) Find theRedisClusterNode
serving given slot.ClusterTopology.getKeyServingMasterNode
(byte[] key) Get theRedisClusterNode
that is the current master serving the given key.ClusterCommandExecutor.NodeResult.getNode()
Get theRedisClusterNode
the command was executed on.Get theRedisClusterNode
matching given nodeId.Get theRedisClusterNode
matching given host and port.ClusterTopology.lookup
(RedisClusterNode node) Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<Map<RedisClusterNode,
Collection<RedisClusterNode>>> ReactiveClusterCommands.clusterGetMasterReplicaMap()
Retrieve information about masters and their connected replicas.reactor.core.publisher.Mono<Map<RedisClusterNode,
Collection<RedisClusterNode>>> ReactiveClusterCommands.clusterGetMasterReplicaMap()
Retrieve information about masters and their connected replicas.RedisClusterCommands.clusterGetMasterReplicaMap()
Retrieve information about masters and their connected replicas.RedisClusterCommands.clusterGetMasterReplicaMap()
Retrieve information about masters and their connected replicas.reactor.core.publisher.Mono<RedisClusterNode>
ReactiveClusterCommands.clusterGetNodeForKey
(ByteBuffer key) Find theRedisClusterNode
serving given key.reactor.core.publisher.Mono<RedisClusterNode>
ReactiveClusterCommands.clusterGetNodeForSlot
(int slot) Find theRedisClusterNode
serving given slot.reactor.core.publisher.Flux<RedisClusterNode>
ReactiveClusterCommands.clusterGetNodes()
Retrieve cluster node information such as id, host, port and slots.RedisClusterCommands.clusterGetNodes()
Retrieve cluster node information such as id, host, port and slots.reactor.core.publisher.Flux<RedisClusterNode>
ReactiveClusterCommands.clusterGetReplicas
(RedisClusterNode master) Retrieve information about connected replicas for given master node.RedisClusterCommands.clusterGetReplicas
(RedisClusterNode master) Retrieve information about connected replicas for given master node.ClusterTopology.getActiveMasterNodes()
Get all master nodes in cluster wherelink-state
is connected andflags
does not contain fail or fail?.ClusterTopology.getActiveNodes()
Get all nodes (master and replica) in cluster wherelink-state
is connected andflags
does not contain fail or fail?.ClusterTopology.getKeyServingNodes
(byte[] key) ClusterTopology.getMasterNodes()
Get all master nodes in cluster.ClusterTopology.getNodes()
Get allRedisClusterNode
s.ClusterTopology.getSlotServingNodes
(int slot) Get theRedisClusterNode
s (master and replica) serving s specific slot.Modifier and TypeMethodDescriptiondefault void
DefaultedRedisClusterConnection.bgReWriteAof
(RedisClusterNode node) Deprecated.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.bgReWriteAof
(RedisClusterNode node) Start an Append Only File rewrite process on the specific server.void
RedisClusterServerCommands.bgReWriteAof
(RedisClusterNode node) default void
DefaultedRedisClusterConnection.bgSave
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.bgSave
(RedisClusterNode node) Start background saving of db on server.void
RedisClusterServerCommands.bgSave
(RedisClusterNode node) reactor.core.publisher.Mono<Void>
ReactiveClusterCommands.clusterAddSlots
(RedisClusterNode node, int... slots) Assign slots to givenRedisClusterNode
.reactor.core.publisher.Mono<Void>
ReactiveClusterCommands.clusterAddSlots
(RedisClusterNode node, RedisClusterNode.SlotRange range) AssignRedisClusterNode.SlotRange.getSlotsArray()
to givenRedisClusterNode
.void
RedisClusterCommands.clusterAddSlots
(RedisClusterNode node, int... slots) Assign slots to givenRedisClusterNode
.void
RedisClusterCommands.clusterAddSlots
(RedisClusterNode node, RedisClusterNode.SlotRange range) AssignRedisClusterNode.SlotRange.getSlotsArray()
to givenRedisClusterNode
.reactor.core.publisher.Mono<Void>
ReactiveClusterCommands.clusterDeleteSlots
(RedisClusterNode node, int... slots) Remove slots fromRedisClusterNode
.void
RedisClusterCommands.clusterDeleteSlots
(RedisClusterNode node, int... slots) Remove slots fromRedisClusterNode
.reactor.core.publisher.Mono<Void>
ReactiveClusterCommands.clusterDeleteSlotsInRange
(RedisClusterNode node, RedisClusterNode.SlotRange range) RemovesRedisClusterNode.SlotRange.getSlotsArray()
from givenRedisClusterNode
.void
RedisClusterCommands.clusterDeleteSlotsInRange
(RedisClusterNode node, RedisClusterNode.SlotRange range) RemovesRedisClusterNode.SlotRange.getSlotsArray()
from givenRedisClusterNode
.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.clusterGetReplicas
(RedisClusterNode master) Retrieve information about connected replicas for given master node.RedisClusterCommands.clusterGetReplicas
(RedisClusterNode master) Retrieve information about connected replicas 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 replica to given master.void
RedisClusterCommands.clusterReplicate
(RedisClusterNode master, RedisClusterNode replica) Assign a replica 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) default Long
DefaultedRedisClusterConnection.dbSize
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<Long>
ReactiveClusterServerCommands.dbSize
(RedisClusterNode node) Get the total number of available keys in currently selected database.RedisClusterServerCommands.dbSize
(RedisClusterNode node) <S,
T> ClusterCommandExecutor.NodeResult<T> ClusterCommandExecutor.executeCommandOnSingleNode
(ClusterCommandExecutor.ClusterCommandCallback<S, T> cmd, RedisClusterNode node) default void
DefaultedRedisClusterConnection.flushAll
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.default void
DefaultedRedisClusterConnection.flushAll
(RedisClusterNode node, RedisServerCommands.FlushOption option) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.flushAll
(RedisClusterNode node) Delete all all keys from all databases.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.flushAll
(RedisClusterNode node, RedisServerCommands.FlushOption option) Delete all all keys from all databases using the specifiedRedisServerCommands.FlushOption
.void
RedisClusterServerCommands.flushAll
(RedisClusterNode node) void
RedisClusterServerCommands.flushAll
(RedisClusterNode node, RedisServerCommands.FlushOption option) default void
DefaultedRedisClusterConnection.flushDb
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.default void
DefaultedRedisClusterConnection.flushDb
(RedisClusterNode node, RedisServerCommands.FlushOption option) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.flushDb
(RedisClusterNode node) Delete all keys of the currently selected database.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.flushDb
(RedisClusterNode node, RedisServerCommands.FlushOption option) Delete all keys of the currently selected database using the specifiedRedisServerCommands.FlushOption
.void
RedisClusterServerCommands.flushDb
(RedisClusterNode node) void
RedisClusterServerCommands.flushDb
(RedisClusterNode node, RedisServerCommands.FlushOption option) default List<RedisClientInfo>
DefaultedRedisClusterConnection.getClientList
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Flux<RedisClientInfo>
ReactiveClusterServerCommands.getClientList
(RedisClusterNode node) Request information and statistics about connected clients.RedisClusterServerCommands.getClientList
(RedisClusterNode node) default Properties
DefaultedRedisClusterConnection.getConfig
(RedisClusterNode node, String pattern) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<Properties>
ReactiveClusterServerCommands.getConfig
(RedisClusterNode node, String pattern) Load configuration parameters for givenpattern
from server.RedisClusterServerCommands.getConfig
(RedisClusterNode node, String pattern) <S> S
ClusterNodeResourceProvider.getResourceForSpecificNode
(RedisClusterNode node) Get the client resource for the given node.default Properties
DefaultedRedisClusterConnection.info
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.default Properties
DefaultedRedisClusterConnection.info
(RedisClusterNode node, String section) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<Properties>
ReactiveClusterServerCommands.info
(RedisClusterNode node) Load default server information like memory cpu utilization replicationreactor.core.publisher.Mono<Properties>
ReactiveClusterServerCommands.info
(RedisClusterNode node, String section) Load server information for givenselection
.RedisClusterServerCommands.info
(RedisClusterNode node) RedisClusterServerCommands.info
(RedisClusterNode node, String section) reactor.core.publisher.Mono<List<ByteBuffer>>
ReactiveClusterKeyCommands.keys
(RedisClusterNode node, ByteBuffer pattern) Retrieve all keys for a given pattern fromRedisNode
.Set<byte[]>
RedisClusterConnection.keys
(RedisClusterNode node, byte[] pattern) default Long
DefaultedRedisClusterConnection.lastSave
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<Long>
ReactiveClusterServerCommands.lastSave
(RedisClusterNode node) Get time unix timestamp of last successfulReactiveServerCommands.bgSave()
operation in seconds.RedisClusterServerCommands.lastSave
(RedisClusterNode node) ClusterTopology.lookup
(RedisClusterNode node) reactor.core.publisher.Mono<String>
ReactiveRedisClusterConnection.ping
(RedisClusterNode node) Test the connection to a specific Redis cluster node.RedisClusterConnection.ping
(RedisClusterNode node) reactor.core.publisher.Mono<ByteBuffer>
ReactiveClusterKeyCommands.randomKey
(RedisClusterNode node) Retrieve a random key fromRedisNode
.byte[]
RedisClusterConnection.randomKey
(RedisClusterNode node) default void
DefaultedRedisClusterConnection.resetConfigStats
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.resetConfigStats
(RedisClusterNode node) Reset statistic counters on server.void
RedisClusterServerCommands.resetConfigStats
(RedisClusterNode node) void
ClusterNodeResourceProvider.returnResourceForSpecificNode
(RedisClusterNode node, Object resource) Return the resource object for the given node.default void
DefaultedRedisClusterConnection.rewriteConfig
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.void
RedisClusterServerCommands.rewriteConfig
(RedisClusterNode node) default void
DefaultedRedisClusterConnection.save
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.save
(RedisClusterNode node) Synchronous save current db snapshot on server.void
RedisClusterServerCommands.save
(RedisClusterNode node) Cursor<byte[]>
RedisClusterConnection.scan
(RedisClusterNode node, ScanOptions options) Use aCursor
to iterate over keys.default void
DefaultedRedisClusterConnection.setConfig
(RedisClusterNode node, String param, String value) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<String>
ReactiveClusterServerCommands.setConfig
(RedisClusterNode node, String param, String value) Set server configuration forparam
tovalue
.void
RedisClusterServerCommands.setConfig
(RedisClusterNode node, String param, String value) default void
DefaultedRedisClusterConnection.shutdown
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.void
RedisClusterServerCommands.shutdown
(RedisClusterNode node) default Long
DefaultedRedisClusterConnection.time
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.default Long
DefaultedRedisClusterConnection.time
(RedisClusterNode node, TimeUnit timeUnit) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.reactor.core.publisher.Mono<Long>
ReactiveClusterServerCommands.time
(RedisClusterNode node) Request server timestamp usingTIME
command.default Long
RedisClusterServerCommands.time
(RedisClusterNode node) RedisClusterServerCommands.time
(RedisClusterNode node, TimeUnit timeUnit) Modifier and TypeMethodDescription<S,
T> ClusterCommandExecutor.MultiNodeResult<T> ClusterCommandExecutor.executeCommandAsyncOnNodes
(ClusterCommandExecutor.ClusterCommandCallback<S, T> callback, Iterable<RedisClusterNode> nodes) ModifierConstructorDescriptionNodeResult
(RedisClusterNode node, T value) Create newClusterCommandExecutor.NodeResult
.NodeResult
(RedisClusterNode node, T value, byte[] key) Create newClusterCommandExecutor.NodeResult
.ModifierConstructorDescriptionClusterTopology
(Set<RedisClusterNode> nodes) Creates new instance ofClusterTopology
. -
Uses of RedisClusterNode in org.springframework.data.redis.connection.convert
Modifier and TypeMethodDescriptionprotected static RedisClusterNode
Converters.toClusterNode
(String clusterNodesLine) Converts the result of a single line ofCLUSTER NODES
into aRedisClusterNode
.Modifier and TypeMethodDescriptionstatic Set<RedisClusterNode>
Converters.toSetOfRedisClusterNodes
(String clusterNodes) Converts the result ofCLUSTER NODES
intoRedisClusterNode
s.static Set<RedisClusterNode>
Converters.toSetOfRedisClusterNodes
(Collection<String> lines) Converts lines from the result ofCLUSTER NODES
intoRedisClusterNode
s. -
Uses of RedisClusterNode in org.springframework.data.redis.connection.jedis
Modifier and TypeMethodDescriptionJedisClusterConnection.clusterGetNodeForKey
(byte[] key) JedisClusterConnection.clusterGetNodeForSlot
(int slot) Modifier and TypeMethodDescriptionJedisClusterConnection.clusterGetMasterReplicaMap()
JedisClusterConnection.clusterGetMasterReplicaMap()
JedisClusterConnection.clusterGetNodes()
JedisClusterConnection.clusterGetReplicas
(RedisClusterNode master) Modifier and TypeMethodDescriptionvoid
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) JedisClusterConnection.clusterGetReplicas
(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) JedisClusterConnection.ping
(RedisClusterNode node) byte[]
JedisClusterConnection.randomKey
(RedisClusterNode node) Cursor<byte[]>
JedisClusterConnection.scan
(RedisClusterNode node, ScanOptions options) -
Uses of RedisClusterNode in org.springframework.data.redis.connection.lettuce
Modifier and TypeMethodDescriptionLettuceClusterConnection.clusterGetNodeForKey
(byte[] key) LettuceClusterConnection.clusterGetNodeForSlot
(int slot) static RedisClusterNode
LettuceConverters.toRedisClusterNode
(io.lettuce.core.cluster.models.partitions.RedisClusterNode source) Modifier and TypeMethodDescriptionLettuceClusterConnection.clusterGetMasterReplicaMap()
LettuceClusterConnection.clusterGetMasterReplicaMap()
LettuceClusterConnection.clusterGetNodes()
LettuceClusterConnection.clusterGetReplicas
(RedisClusterNode master) static List<RedisClusterNode>
LettuceConverters.partitionsToClusterNodes
(io.lettuce.core.cluster.models.partitions.Partitions source) Modifier and TypeMethodDescriptionvoid
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) LettuceClusterConnection.clusterGetReplicas
(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) LettuceClusterConnection.ping
(RedisClusterNode node) byte[]
LettuceClusterConnection.randomKey
(RedisClusterNode node) Cursor<byte[]>
LettuceClusterConnection.scan
(RedisClusterNode node, ScanOptions options) -
Uses of RedisClusterNode in org.springframework.data.redis.core
Modifier and TypeMethodDescriptionvoid
ClusterOperations.addSlots
(RedisClusterNode node, int... slots) Add slots to given node;void
ClusterOperations.addSlots
(RedisClusterNode node, RedisClusterNode.SlotRange range) Add slots inRedisClusterNode.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.flushDb
(RedisClusterNode node, RedisServerCommands.FlushOption option) Flush db on node using the specifiedRedisServerCommands.FlushOption
.void
ClusterOperations.forget
(RedisClusterNode node) Remove the node from the cluster.ClusterOperations.getReplicas
(RedisClusterNode node) ClusterOperations.keys
(RedisClusterNode node, K pattern) Get all keys located at given node.void
ClusterOperations.meet
(RedisClusterNode node) Add the node to cluster.ClusterOperations.ping
(RedisClusterNode node) Ping the given node;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.
RedisCommandsProvider.serverCommands()
.