Uses of Class
org.springframework.data.redis.connection.RedisClusterNode
Packages that use 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
Methods in org.springframework.data.redis.connection that return RedisClusterNodeModifier and TypeMethodDescriptionRedisClusterNode.RedisClusterNodeBuilder.build()
RedisClusterCommands.clusterGetNodeForKey
(byte @NonNull [] 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) Methods in org.springframework.data.redis.connection that return types with arguments of type RedisClusterNodeModifier and TypeMethodDescriptionReactiveClusterCommands.clusterGetMasterReplicaMap()
Retrieve information about masters and their connected replicas.ReactiveClusterCommands.clusterGetMasterReplicaMap()
Retrieve information about masters and their connected replicas.Map<@NonNull RedisClusterNode,
@NonNull Collection<@NonNull RedisClusterNode>> RedisClusterCommands.clusterGetMasterReplicaMap()
Retrieve information about masters and their connected replicas.Map<@NonNull RedisClusterNode,
@NonNull Collection<@NonNull RedisClusterNode>> RedisClusterCommands.clusterGetMasterReplicaMap()
Retrieve information about masters and their connected replicas.ReactiveClusterCommands.clusterGetNodeForKey
(ByteBuffer key) Find theRedisClusterNode
serving given key.ReactiveClusterCommands.clusterGetNodeForSlot
(int slot) Find theRedisClusterNode
serving given slot.ReactiveClusterCommands.clusterGetNodes()
Retrieve cluster node information such as id, host, port and slots.Iterable<@NonNull RedisClusterNode>
RedisClusterCommands.clusterGetNodes()
Retrieve cluster node information such as id, host, port and slots.ReactiveClusterCommands.clusterGetReplicas
(RedisClusterNode master) Retrieve information about connected replicas for given master node.Collection<@NonNull RedisClusterNode>
RedisClusterCommands.clusterGetReplicas
(@NonNull 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.Methods in org.springframework.data.redis.connection with parameters of type RedisClusterNodeModifier and TypeMethodDescriptiondefault void
DefaultedRedisClusterConnection.bgReWriteAof
(RedisClusterNode node) Deprecated.ReactiveClusterServerCommands.bgReWriteAof
(RedisClusterNode node) Start an Append Only File rewrite process on the specific server.void
RedisClusterServerCommands.bgReWriteAof
(@NonNull RedisClusterNode node) default void
DefaultedRedisClusterConnection.bgSave
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.ReactiveClusterServerCommands.bgSave
(RedisClusterNode node) Start background saving of db on server.void
RedisClusterServerCommands.bgSave
(@NonNull RedisClusterNode node) ReactiveClusterCommands.clusterAddSlots
(RedisClusterNode node, int... slots) Assign slots to givenRedisClusterNode
.ReactiveClusterCommands.clusterAddSlots
(RedisClusterNode node, RedisClusterNode.SlotRange range) AssignRedisClusterNode.SlotRange.getSlotsArray()
to givenRedisClusterNode
.void
RedisClusterCommands.clusterAddSlots
(@NonNull RedisClusterNode node, int @NonNull ... slots) Assign slots to givenRedisClusterNode
.void
RedisClusterCommands.clusterAddSlots
(@NonNull RedisClusterNode node, @NonNull RedisClusterNode.SlotRange range) AssignRedisClusterNode.SlotRange.getSlotsArray()
to givenRedisClusterNode
.ReactiveClusterCommands.clusterDeleteSlots
(RedisClusterNode node, int... slots) Remove slots fromRedisClusterNode
.void
RedisClusterCommands.clusterDeleteSlots
(@NonNull RedisClusterNode node, int @NonNull ... slots) Remove slots fromRedisClusterNode
.ReactiveClusterCommands.clusterDeleteSlotsInRange
(RedisClusterNode node, RedisClusterNode.SlotRange range) RemovesRedisClusterNode.SlotRange.getSlotsArray()
from givenRedisClusterNode
.void
RedisClusterCommands.clusterDeleteSlotsInRange
(@NonNull RedisClusterNode node, @NonNull RedisClusterNode.SlotRange range) RemovesRedisClusterNode.SlotRange.getSlotsArray()
from givenRedisClusterNode
.ReactiveClusterCommands.clusterForget
(RedisClusterNode node) Remove given node from cluster.void
RedisClusterCommands.clusterForget
(@NonNull RedisClusterNode node) Remove given node from cluster.ReactiveClusterCommands.clusterGetReplicas
(RedisClusterNode master) Retrieve information about connected replicas for given master node.Collection<@NonNull RedisClusterNode>
RedisClusterCommands.clusterGetReplicas
(@NonNull RedisClusterNode master) Retrieve information about connected replicas for given master node.ReactiveClusterCommands.clusterMeet
(RedisClusterNode node) Add given node to cluster.void
RedisClusterCommands.clusterMeet
(@NonNull RedisClusterNode node) Add given node to cluster.ReactiveClusterCommands.clusterReplicate
(RedisClusterNode master, RedisClusterNode replica) Assign a replica to given master.void
RedisClusterCommands.clusterReplicate
(@NonNull RedisClusterNode master, @NonNull RedisClusterNode replica) Assign a replica to given master.ReactiveClusterCommands.clusterSetSlot
(RedisClusterNode node, int slot, ReactiveClusterCommands.AddSlots mode) void
RedisClusterCommands.clusterSetSlot
(@NonNull RedisClusterNode node, int slot, @NonNull RedisClusterCommands.AddSlots mode) default Long
DefaultedRedisClusterConnection.dbSize
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.ReactiveClusterServerCommands.dbSize
(RedisClusterNode node) Get the total number of available keys in currently selected database.RedisClusterServerCommands.dbSize
(@NonNull RedisClusterNode node) <S,
T> ClusterCommandExecutor.NodeResult<T> ClusterCommandExecutor.executeCommandOnSingleNode
(ClusterCommandExecutor.ClusterCommandCallback<S, T> commandCallback, 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()
.ReactiveClusterServerCommands.flushAll
(RedisClusterNode node) Delete all all keys from all databases.ReactiveClusterServerCommands.flushAll
(RedisClusterNode node, RedisServerCommands.FlushOption option) Delete all all keys from all databases using the specifiedRedisServerCommands.FlushOption
.void
RedisClusterServerCommands.flushAll
(@NonNull RedisClusterNode node) void
RedisClusterServerCommands.flushAll
(@NonNull RedisClusterNode node, @NonNull 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()
.ReactiveClusterServerCommands.flushDb
(RedisClusterNode node) Delete all keys of the currently selected database.ReactiveClusterServerCommands.flushDb
(RedisClusterNode node, RedisServerCommands.FlushOption option) Delete all keys of the currently selected database using the specifiedRedisServerCommands.FlushOption
.void
RedisClusterServerCommands.flushDb
(@NonNull RedisClusterNode node) void
RedisClusterServerCommands.flushDb
(@NonNull RedisClusterNode node, @NonNull RedisServerCommands.FlushOption option) default List<RedisClientInfo>
DefaultedRedisClusterConnection.getClientList
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.ReactiveClusterServerCommands.getClientList
(RedisClusterNode node) Request information and statistics about connected clients.List<@NonNull RedisClientInfo>
RedisClusterServerCommands.getClientList
(@NonNull RedisClusterNode node) default Properties
DefaultedRedisClusterConnection.getConfig
(RedisClusterNode node, String pattern) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.ReactiveClusterServerCommands.getConfig
(RedisClusterNode node, String pattern) Load configuration parameters for givenpattern
from server.RedisClusterServerCommands.getConfig
(@NonNull RedisClusterNode node, @NonNull 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()
.ReactiveClusterServerCommands.info
(RedisClusterNode node) Load default server information like memory cpu utilization replicationReactiveClusterServerCommands.info
(RedisClusterNode node, String section) Load server information for givenselection
.RedisClusterServerCommands.info
(@NonNull RedisClusterNode node) RedisClusterServerCommands.info
(@NonNull RedisClusterNode node, @NonNull String section) ReactiveClusterKeyCommands.keys
(RedisClusterNode node, ByteBuffer pattern) Retrieve all keys for a given pattern fromRedisNode
.Set<byte @NonNull []>
RedisClusterConnection.keys
(@NonNull RedisClusterNode node, byte @NonNull [] pattern) default Long
DefaultedRedisClusterConnection.lastSave
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.ReactiveClusterServerCommands.lastSave
(RedisClusterNode node) Get time unix timestamp of last successfulReactiveServerCommands.bgSave()
operation in seconds.RedisClusterServerCommands.lastSave
(@NonNull RedisClusterNode node) ClusterTopology.lookup
(RedisClusterNode node) ReactiveRedisClusterConnection.ping
(RedisClusterNode node) Test the connection to a specific Redis cluster node.RedisClusterConnection.ping
(@NonNull RedisClusterNode node) ReactiveClusterKeyCommands.randomKey
(RedisClusterNode node) Retrieve a random key fromRedisNode
.byte[]
RedisClusterConnection.randomKey
(@NonNull RedisClusterNode node) default void
DefaultedRedisClusterConnection.resetConfigStats
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.ReactiveClusterServerCommands.resetConfigStats
(RedisClusterNode node) Reset statistic counters on server.void
RedisClusterServerCommands.resetConfigStats
(@NonNull 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
(@NonNull RedisClusterNode node) default void
DefaultedRedisClusterConnection.save
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.ReactiveClusterServerCommands.save
(RedisClusterNode node) Synchronous save current db snapshot on server.void
RedisClusterServerCommands.save
(@NonNull RedisClusterNode node) Cursor<byte @NonNull []>
RedisClusterConnection.scan
(@NonNull RedisClusterNode node, @NonNull ScanOptions options) Use aCursor
to iterate over keys.default void
DefaultedRedisClusterConnection.setConfig
(RedisClusterNode node, String param, String value) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.ReactiveClusterServerCommands.setConfig
(RedisClusterNode node, String param, String value) Set server configuration forparam
tovalue
.void
RedisClusterServerCommands.setConfig
(@NonNull RedisClusterNode node, @NonNull String param, @NonNull String value) default void
DefaultedRedisClusterConnection.shutdown
(RedisClusterNode node) Deprecated.in favor ofRedisCommandsProvider.serverCommands()
.void
RedisClusterServerCommands.shutdown
(@NonNull 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()
.ReactiveClusterServerCommands.time
(RedisClusterNode node) Request server timestamp usingTIME
command.default Long
RedisClusterServerCommands.time
(@NonNull RedisClusterNode node) RedisClusterServerCommands.time
(@NonNull RedisClusterNode node, @NonNull TimeUnit timeUnit) Method parameters in org.springframework.data.redis.connection with type arguments of type RedisClusterNodeModifier and TypeMethodDescription<S,
T> ClusterCommandExecutor.MultiNodeResult<T> ClusterCommandExecutor.executeCommandAsyncOnNodes
(ClusterCommandExecutor.ClusterCommandCallback<S, T> commandCallback, Iterable<RedisClusterNode> nodes) Constructors in org.springframework.data.redis.connection with parameters of type RedisClusterNodeModifierConstructorDescriptionNodeResult
(RedisClusterNode node, @Nullable T value) Create a newClusterCommandExecutor.NodeResult
.NodeResult
(RedisClusterNode node, @Nullable T value, byte[] key) Create a newClusterCommandExecutor.NodeResult
.Constructor parameters in org.springframework.data.redis.connection with type arguments of type RedisClusterNodeModifierConstructorDescriptionClusterTopology
(@Nullable Set<RedisClusterNode> nodes) Creates new instance ofClusterTopology
. -
Uses of RedisClusterNode in org.springframework.data.redis.connection.convert
Methods in org.springframework.data.redis.connection.convert that return RedisClusterNodeModifier and TypeMethodDescriptionprotected static RedisClusterNode
Converters.toClusterNode
(String clusterNodesLine) Converts the result of a single line ofCLUSTER NODES
into aRedisClusterNode
.Methods in org.springframework.data.redis.connection.convert that return types with arguments of type RedisClusterNodeModifier 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
Methods in org.springframework.data.redis.connection.jedis that return RedisClusterNodeModifier and TypeMethodDescriptionJedisClusterConnection.clusterGetNodeForKey
(byte @NonNull [] key) JedisClusterConnection.clusterGetNodeForSlot
(int slot) Methods in org.springframework.data.redis.connection.jedis that return types with arguments of type RedisClusterNodeModifier and TypeMethodDescriptionJedisClusterConnection.clusterGetMasterReplicaMap()
JedisClusterConnection.clusterGetMasterReplicaMap()
JedisClusterConnection.clusterGetNodes()
JedisClusterConnection.clusterGetReplicas
(@NonNull RedisClusterNode master) Methods in org.springframework.data.redis.connection.jedis with parameters of type RedisClusterNodeModifier and TypeMethodDescriptionvoid
JedisClusterConnection.clusterAddSlots
(@NonNull RedisClusterNode node, int @NonNull ... slots) void
JedisClusterConnection.clusterAddSlots
(@NonNull RedisClusterNode node, @NonNull RedisClusterNode.SlotRange range) void
JedisClusterConnection.clusterDeleteSlots
(@NonNull RedisClusterNode node, int @NonNull ... slots) void
JedisClusterConnection.clusterDeleteSlotsInRange
(@NonNull RedisClusterNode node, @NonNull RedisClusterNode.SlotRange range) void
JedisClusterConnection.clusterForget
(@NonNull RedisClusterNode node) JedisClusterConnection.clusterGetReplicas
(@NonNull RedisClusterNode master) void
JedisClusterConnection.clusterMeet
(@NonNull RedisClusterNode node) void
JedisClusterConnection.clusterReplicate
(@NonNull RedisClusterNode master, @NonNull RedisClusterNode replica) void
JedisClusterConnection.clusterSetSlot
(@NonNull RedisClusterNode node, int slot, @NonNull RedisClusterCommands.AddSlots mode) Set<byte[]>
JedisClusterConnection.keys
(RedisClusterNode node, byte[] pattern) JedisClusterConnection.ping
(@NonNull 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
Methods in org.springframework.data.redis.connection.lettuce that return RedisClusterNodeModifier and TypeMethodDescription@Nullable RedisClusterNode
LettuceClusterConnection.clusterGetNodeForKey
(byte[] key) @Nullable RedisClusterNode
LettuceClusterConnection.clusterGetNodeForSlot
(int slot) static RedisClusterNode
LettuceConverters.toRedisClusterNode
(io.lettuce.core.cluster.models.partitions.RedisClusterNode source) Methods in org.springframework.data.redis.connection.lettuce that return types with arguments of type RedisClusterNodeModifier and TypeMethodDescriptionLettuceClusterConnection.clusterGetMasterReplicaMap()
LettuceClusterConnection.clusterGetMasterReplicaMap()
LettuceClusterConnection.clusterGetNodes()
LettuceClusterConnection.clusterGetReplicas
(RedisClusterNode master) static List<RedisClusterNode>
LettuceConverters.partitionsToClusterNodes
(@Nullable io.lettuce.core.cluster.models.partitions.Partitions source) Methods in org.springframework.data.redis.connection.lettuce with parameters of type RedisClusterNodeModifier 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) @Nullable Set<byte[]>
LettuceClusterConnection.keys
(RedisClusterNode node, byte[] pattern) @Nullable String
LettuceClusterConnection.ping
(RedisClusterNode node) byte @Nullable []
LettuceClusterConnection.randomKey
(RedisClusterNode node) Cursor<byte[]>
LettuceClusterConnection.scan
(RedisClusterNode node, ScanOptions options) -
Uses of RedisClusterNode in org.springframework.data.redis.core
Methods in org.springframework.data.redis.core that return types with arguments of type RedisClusterNodeModifier and TypeMethodDescriptionCollection<@NonNull RedisClusterNode>
ClusterOperations.getReplicas
(@NonNull RedisClusterNode node) Methods in org.springframework.data.redis.core with parameters of type RedisClusterNodeModifier and TypeMethodDescriptionvoid
ClusterOperations.addSlots
(@NonNull RedisClusterNode node, int... slots) Add slots to given node;void
ClusterOperations.addSlots
(@NonNull RedisClusterNode node, @NonNull RedisClusterNode.SlotRange range) Add slots inRedisClusterNode.SlotRange
to given node.void
ClusterOperations.bgReWriteAof
(@NonNull RedisClusterNode node) Start an Append Only File rewrite process on given node.void
ClusterOperations.bgSave
(@NonNull RedisClusterNode node) Start background saving of db on given node.void
ClusterOperations.flushDb
(@NonNull RedisClusterNode node) Flush db on node.void
ClusterOperations.flushDb
(@NonNull RedisClusterNode node, @NonNull RedisServerCommands.FlushOption option) Flush db on node using the specifiedRedisServerCommands.FlushOption
.void
ClusterOperations.forget
(@NonNull RedisClusterNode node) Remove the node from the cluster.Collection<@NonNull RedisClusterNode>
ClusterOperations.getReplicas
(@NonNull RedisClusterNode node) ClusterOperations.keys
(@NonNull RedisClusterNode node, @NonNull K pattern) Retrieve all keys located at given node matching the given pattern.void
ClusterOperations.meet
(@NonNull RedisClusterNode node) Add the node to cluster.ClusterOperations.ping
(@NonNull RedisClusterNode node) Ping the given node;ClusterOperations.randomKey
(@NonNull RedisClusterNode node) Get a random key from the range served by the given node.void
ClusterOperations.reshard
(@NonNull RedisClusterNode source, int slot, @NonNull RedisClusterNode target) Move slot assignment from one source to target node and copy keys associated with the slot.void
ClusterOperations.save
(@NonNull RedisClusterNode node) Synchronous save current db snapshot on server.void
ClusterOperations.shutdown
(@NonNull RedisClusterNode node) Shutdown given node.
RedisCommandsProvider.serverCommands()
.