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 TypeMethodDescriptionreactor.core.publisher.Mono<String>
bgReWriteAof
(RedisClusterNode node) Start an Append Only File rewrite process on the specific server.reactor.core.publisher.Mono<String>
bgSave
(RedisClusterNode node) Start background saving of db on server.reactor.core.publisher.Mono<Long>
dbSize
(RedisClusterNode node) Get the total number of available keys in currently selected database.reactor.core.publisher.Mono<String>
flushAll
(RedisClusterNode node) Delete all all keys from all databases.reactor.core.publisher.Mono<String>
flushAll
(RedisClusterNode node, RedisServerCommands.FlushOption option) Delete all all keys from all databases using the specifiedRedisServerCommands.FlushOption
.reactor.core.publisher.Mono<String>
flushDb
(RedisClusterNode node) Delete all keys of the currently selected database.reactor.core.publisher.Mono<String>
flushDb
(RedisClusterNode node, RedisServerCommands.FlushOption option) Delete all keys of the currently selected database using the specifiedRedisServerCommands.FlushOption
.reactor.core.publisher.Flux<RedisClientInfo>
Request information and statistics about connected clients.reactor.core.publisher.Mono<Properties>
getConfig
(RedisClusterNode node, String pattern) Load configuration parameters for givenpattern
from server.reactor.core.publisher.Mono<Properties>
info
(RedisClusterNode node) Load default server information like memory cpu utilization replicationreactor.core.publisher.Mono<Properties>
info
(RedisClusterNode node, String section) Load server information for givenselection
.reactor.core.publisher.Mono<Long>
lastSave
(RedisClusterNode node) Get time unix timestamp of last successfulReactiveServerCommands.bgSave()
operation in seconds.reactor.core.publisher.Mono<String>
Reset statistic counters on server.reactor.core.publisher.Mono<String>
save
(RedisClusterNode node) Synchronous save current db snapshot on server.reactor.core.publisher.Mono<String>
setConfig
(RedisClusterNode node, String param, String value) Set server configuration forparam
tovalue
.reactor.core.publisher.Mono<Long>
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
reactor.core.publisher.Mono<String> flushDb(RedisClusterNode node, RedisServerCommands.FlushOption option) 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
reactor.core.publisher.Mono<String> flushAll(RedisClusterNode node, RedisServerCommands.FlushOption option) 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:
-