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. |
default reactor.core.publisher.Mono<Long> |
time()
Request server timestamp using
TIME command in TimeUnit.MILLISECONDS. |
reactor.core.publisher.Mono<Long> |
time(TimeUnit timeUnit)
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.default reactor.core.publisher.Mono<Long> time()
TIME command in TimeUnit.MILLISECONDS.Mono wrapping current server time in milliseconds.reactor.core.publisher.Mono<Long> time(TimeUnit timeUnit)
TIME command.timeUnit - target unit.Mono wrapping current server time in TimeUnit.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–2022 Pivotal Software, Inc.. All rights reserved.