Interface ReactiveClusterServerCommands
- All Superinterfaces:
ReactiveServerCommands
Redis Server commands executed in cluster environment using reactive infrastructure.
- Since:
- 2.0
- Author:
- Mark Paluch, Christoph Strobl, Dennis Neufeld
-
Method Summary
Modifier and TypeMethodDescriptionbgReWriteAof
(RedisClusterNode node) Start an Append Only File rewrite process on the specific server.bgSave
(RedisClusterNode node) Start background saving of db on server.dbSize
(RedisClusterNode node) Get the total number of available keys in currently selected database.flushAll
(RedisClusterNode node) Delete all all keys from all databases.flushAll
(RedisClusterNode node, RedisServerCommands.FlushOption option) Delete all all keys from all databases using the specifiedRedisServerCommands.FlushOption
.flushDb
(RedisClusterNode node) Delete all keys of the currently selected database.flushDb
(RedisClusterNode node, RedisServerCommands.FlushOption option) Delete all keys of the currently selected database using the specifiedRedisServerCommands.FlushOption
.Request information and statistics about connected clients.getConfig
(RedisClusterNode node, String pattern) Load configuration parameters for givenpattern
from server.info
(RedisClusterNode node) Load default server information like memory cpu utilization replicationinfo
(RedisClusterNode node, String section) Load server information for givenselection
.lastSave
(RedisClusterNode node) Get time unix timestamp of last successfulReactiveServerCommands.bgSave()
operation in seconds.Reset statistic counters on server.save
(RedisClusterNode node) Synchronous save current db snapshot on server.setConfig
(RedisClusterNode node, String param, String value) Set server configuration forparam
tovalue
.time
(RedisClusterNode node) Request server timestamp usingTIME
command.Methods inherited from interface org.springframework.data.redis.connection.ReactiveServerCommands
bgReWriteAof, bgSave, dbSize, flushAll, flushAll, flushDb, flushDb, getClientList, getClientName, getConfig, info, info, killClient, lastSave, resetConfigStats, save, setClientName, setConfig, time, time
-
Method Details
-
bgReWriteAof
Start an Append Only File rewrite process on the specific server.- Parameters:
node
- must not be null.- Returns:
Mono
indicating command completion.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
bgSave
Start background saving of db on server.- Parameters:
node
- must not be null.- Returns:
Mono
indicating command received by server. Operation success needs to be checked vialastSave(RedisClusterNode)
.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
lastSave
Get time unix timestamp of last successfulReactiveServerCommands.bgSave()
operation in seconds.- Parameters:
node
- must not be null.- Returns:
Mono
wrapping unix timestamp.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
save
Synchronous save current db snapshot on server.- Parameters:
node
- must not be null.- Returns:
Mono
indicating command completion.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
dbSize
Get the total number of available keys in currently selected database.- Parameters:
node
- must not be null.- Returns:
Mono
wrapping number of keys.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
flushDb
Delete all keys of the currently selected database.- Parameters:
node
- must not be null.Mono
indicating command completion.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
flushDb
Delete all keys of the currently selected database using the specifiedRedisServerCommands.FlushOption
.- Parameters:
node
- must not be null.Mono
indicating command completion.option
-- Throws:
IllegalArgumentException
- whennode
is null.- Since:
- 2.7
- See Also:
-
flushAll
Delete all all keys from all databases.- Parameters:
node
- must not be null.- Returns:
Mono
indicating command completion.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
flushAll
Delete all all keys from all databases using the specifiedRedisServerCommands.FlushOption
.- Parameters:
node
- must not be null.option
-- Returns:
Mono
indicating command completion.- Throws:
IllegalArgumentException
- whennode
is null.- Since:
- 2.7
- See Also:
-
info
Load default server information like- memory
- cpu utilization
- replication
- Parameters:
node
- must not be null.- Returns:
Mono
wrapping server information.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
info
Load server information for givenselection
.- Parameters:
node
- must not be null.section
- must not be null nor empty.- Returns:
Mono
wrapping server information of givensection
.- Throws:
IllegalArgumentException
- whennode
is null.IllegalArgumentException
- when section is null or empty.- See Also:
-
getConfig
Load configuration parameters for givenpattern
from server.- Parameters:
node
- must not be null.pattern
- must not be null.- Returns:
Mono
wrapping configuration parameters matching givenpattern
.- Throws:
IllegalArgumentException
- whennode
is null.IllegalArgumentException
- whenpattern
is null or empty.- See Also:
-
setConfig
Set server configuration forparam
tovalue
.- Parameters:
node
- must not be null.param
- must not be null nor empty.value
- must not be null nor empty.- Throws:
IllegalArgumentException
- whennode
is null.IllegalArgumentException
- whenpattern
/value
is null or empty.- See Also:
-
resetConfigStats
Reset statistic counters on server.
Counters can be retrieved usingReactiveServerCommands.info()
.- Parameters:
node
- must not be null.- Returns:
Mono
indicating command completion.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
time
Request server timestamp usingTIME
command.- Parameters:
node
- must not be null.- Returns:
Mono
wrapping current server time in milliseconds.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-
getClientList
Request information and statistics about connected clients.- Parameters:
node
- must not be null.- Returns:
Flux
emittingRedisClientInfo
objects.- Throws:
IllegalArgumentException
- whennode
is null.- See Also:
-