public interface ReactiveServerCommands
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<String> |
bgReWriteAof()
Start an Append Only File rewrite process on server.
|
reactor.core.publisher.Mono<String> |
bgSave()
Start background saving of db on server.
|
reactor.core.publisher.Mono<Long> |
dbSize()
Get the total number of available keys in currently selected database.
|
reactor.core.publisher.Mono<String> |
flushAll()
Delete all all keys from all databases.
|
reactor.core.publisher.Mono<String> |
flushDb()
Delete all keys of the currently selected database.
|
reactor.core.publisher.Flux<RedisClientInfo> |
getClientList()
Request information and statistics about connected clients.
|
reactor.core.publisher.Mono<String> |
getClientName()
Returns the name of the current connection.
|
reactor.core.publisher.Mono<Properties> |
getConfig(String pattern)
Load configuration parameters for given
pattern from server. |
reactor.core.publisher.Mono<Properties> |
info()
Load default server information like
memory
cpu utilization
replication
|
reactor.core.publisher.Mono<Properties> |
info(String section)
Load server information for given
selection . |
reactor.core.publisher.Mono<String> |
killClient(String host,
int port)
Closes a given client connection identified by host:port.
|
reactor.core.publisher.Mono<Long> |
lastSave()
Get time unix timestamp of last successful
bgSave() operation in seconds. |
reactor.core.publisher.Mono<String> |
resetConfigStats()
Reset statistic counters on server.
|
reactor.core.publisher.Mono<String> |
save()
Synchronous save current db snapshot on server.
|
reactor.core.publisher.Mono<String> |
setClientName(String name)
Assign given name to current connection.
|
reactor.core.publisher.Mono<String> |
setConfig(String param,
String value)
Set server configuration for
param to value . |
reactor.core.publisher.Mono<Long> |
time()
Request server timestamp using
TIME command. |
reactor.core.publisher.Mono<String> bgReWriteAof()
Mono
indicating command completion.reactor.core.publisher.Mono<String> bgSave()
Mono
indicating command received by server. Operation success needs to be checked via
lastSave()
.reactor.core.publisher.Mono<Long> lastSave()
bgSave()
operation in seconds.Mono
wrapping unix timestamp.reactor.core.publisher.Mono<String> save()
Mono
indicating command completion.reactor.core.publisher.Mono<Long> dbSize()
Mono
wrapping number of keys.reactor.core.publisher.Mono<String> flushDb()
Mono
indicating command completion.reactor.core.publisher.Mono<String> flushAll()
Mono
indicating command completion.reactor.core.publisher.Mono<Properties> info()
Mono
wrapping server information.reactor.core.publisher.Mono<Properties> info(String section)
selection
.section
- must not be null nor empty.Mono
wrapping server information of given section
.IllegalArgumentException
- when section is null or empty.reactor.core.publisher.Mono<Properties> getConfig(String pattern)
pattern
from server.pattern
- must not be null.Mono
wrapping configuration parameters matching given pattern
.IllegalArgumentException
- when pattern
is null or empty.reactor.core.publisher.Mono<String> setConfig(String param, String value)
param
to value
.param
- must not be null nor empty.value
- must not be null nor empty.IllegalArgumentException
- when pattern
/ value
is null or empty.reactor.core.publisher.Mono<String> resetConfigStats()
info()
.Mono
indicating command completion.reactor.core.publisher.Mono<Long> time()
TIME
command.Mono
wrapping current server time in milliseconds.reactor.core.publisher.Mono<String> killClient(String host, int port)
host
- of connection to close. Must not be null nor empty.port
- of connection to closeMono
wrapping String
representation of the command result.IllegalArgumentException
- if host
is null or empty.reactor.core.publisher.Mono<String> setClientName(String name)
name
- must not be null nor empty.IllegalArgumentException
- when name
is null or empty.reactor.core.publisher.Mono<String> getClientName()
Mono
wrapping the connection name.reactor.core.publisher.Flux<RedisClientInfo> getClientList()
Flux
emitting RedisClientInfo
objects.Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.