K
- Key type.V
- Value type.public interface NodeSelectionServerAsyncCommands<K,V>
Modifier and Type | Method and Description |
---|---|
AsyncExecutions<String> |
bgrewriteaof()
Asynchronously rewrite the append-only file.
|
AsyncExecutions<String> |
bgsave()
Asynchronously save the dataset to disk.
|
AsyncExecutions<String> |
clientCaching(boolean enabled)
Control tracking of keys in the context of server-assisted client cache invalidation.
|
AsyncExecutions<K> |
clientGetname()
Get the current connection name.
|
AsyncExecutions<Long> |
clientGetredir()
Returns the client ID we are redirecting our tracking notifications to.
|
AsyncExecutions<Long> |
clientId()
Get the id of the current connection.
|
AsyncExecutions<Long> |
clientKill(KillArgs killArgs)
Kill connections of clients which are filtered by
killArgs . |
AsyncExecutions<String> |
clientKill(String addr)
Kill the connection of a client identified by ip:port.
|
AsyncExecutions<String> |
clientList()
Get the list of client connections.
|
AsyncExecutions<String> |
clientNoEvict(boolean on)
Sets the client eviction mode for the current connection.
|
AsyncExecutions<String> |
clientPause(long timeout)
Stop processing commands from clients for some time.
|
AsyncExecutions<String> |
clientSetname(K name)
Set the current connection name.
|
AsyncExecutions<String> |
clientTracking(TrackingArgs args)
Enables the tracking feature of the Redis server, that is used for server assisted client side caching.
|
AsyncExecutions<Long> |
clientUnblock(long id,
UnblockType type)
Unblock the specified blocked client.
|
AsyncExecutions<List<Object>> |
command()
Returns an array reply of details about all Redis commands.
|
AsyncExecutions<Long> |
commandCount()
Get total number of Redis commands.
|
AsyncExecutions<List<Object>> |
commandInfo(CommandType... commands)
Returns an array reply of details about the requested commands.
|
AsyncExecutions<List<Object>> |
commandInfo(String... commands)
Returns an array reply of details about the requested commands.
|
AsyncExecutions<Map<String,String>> |
configGet(String... parameters)
Get the value of multiple pattern parameters.
|
AsyncExecutions<Map<String,String>> |
configGet(String parameter)
Get the value of a configuration parameter.
|
AsyncExecutions<String> |
configResetstat()
Reset the stats returned by INFO.
|
AsyncExecutions<String> |
configRewrite()
Rewrite the configuration file with the in memory configuration.
|
AsyncExecutions<String> |
configSet(Map<String,String> kvs)
Set multiple parameters to the given value.
|
AsyncExecutions<String> |
configSet(String parameter,
String value)
Set a configuration parameter to the given value.
|
AsyncExecutions<Long> |
dbsize()
Return the number of keys in the selected database.
|
AsyncExecutions<String> |
debugCrashAndRecover(Long delay)
Crash and recover.
|
AsyncExecutions<String> |
debugHtstats(int db)
Get debugging information about the internal hash-table state.
|
AsyncExecutions<String> |
debugObject(K key)
Get debugging information about a key.
|
AsyncExecutions<String> |
debugReload()
Save RDB, clear the database and reload RDB.
|
AsyncExecutions<String> |
debugRestart(Long delay)
Restart the server gracefully.
|
AsyncExecutions<String> |
debugSdslen(K key)
Get debugging information about the internal SDS length.
|
AsyncExecutions<String> |
flushall()
Remove all keys from all databases.
|
AsyncExecutions<String> |
flushall(FlushMode flushMode)
Remove all keys from all databases using the specified
FlushMode . |
AsyncExecutions<String> |
flushallAsync()
Deprecated.
since 6.1, use
flushall(FlushMode) instead. |
AsyncExecutions<String> |
flushdb()
Remove all keys from the current database.
|
AsyncExecutions<String> |
flushdb(FlushMode flushMode)
Remove all keys from the current database using the specified
FlushMode . |
AsyncExecutions<String> |
flushdbAsync()
Deprecated.
since 6.1, use
flushdb(FlushMode) instead. |
AsyncExecutions<String> |
info()
Get information and statistics about the server.
|
AsyncExecutions<String> |
info(String section)
Get information and statistics about the server.
|
AsyncExecutions<Date> |
lastsave()
Get the UNIX time stamp of the last successful save to disk.
|
AsyncExecutions<Long> |
memoryUsage(K key)
Reports the number of bytes that a key and its value require to be stored in RAM.
|
AsyncExecutions<String> |
replicaof(String host,
int port)
Make the server a replica of another instance.
|
AsyncExecutions<String> |
replicaofNoOne()
Promote server as master.
|
AsyncExecutions<String> |
save()
Synchronously save the dataset to disk.
|
AsyncExecutions<String> |
slaveof(String host,
int port)
Deprecated.
since 6.1.7, use
replicaof(String, int) instead. |
AsyncExecutions<String> |
slaveofNoOne()
Deprecated.
since 6.1.7, use
replicaofNoOne() instead. |
AsyncExecutions<List<Object>> |
slowlogGet()
Read the slow log.
|
AsyncExecutions<List<Object>> |
slowlogGet(int count)
Read the slow log.
|
AsyncExecutions<Long> |
slowlogLen()
Obtaining the current length of the slow log.
|
AsyncExecutions<String> |
slowlogReset()
Resetting the slow log.
|
AsyncExecutions<List<V>> |
time()
Return the current server time.
|
AsyncExecutions<String> bgrewriteaof()
OK
.AsyncExecutions<String> bgsave()
AsyncExecutions<String> clientCaching(boolean enabled)
enabled
- true
to enable key tracking.OK
.AsyncExecutions<K> clientGetname()
AsyncExecutions<Long> clientGetredir()
AsyncExecutions<Long> clientId()
AsyncExecutions<String> clientKill(String addr)
addr
- ip:port.OK
if the connection exists and has been closed.AsyncExecutions<Long> clientKill(KillArgs killArgs)
killArgs
.killArgs
- args for the kill operation.AsyncExecutions<String> clientList()
AsyncExecutions<String> clientNoEvict(boolean on)
on
- true
will turn eviction mode on, and false
will turn it off.OK
.AsyncExecutions<String> clientPause(long timeout)
timeout
- the timeout value in milliseconds.AsyncExecutions<String> clientSetname(K name)
name
- the client name.OK
if the connection name was successfully set.AsyncExecutions<String> clientTracking(TrackingArgs args)
args
- for the CLIENT TRACKING operation.OK
.AsyncExecutions<Long> clientUnblock(long id, UnblockType type)
id
- the client id.type
- unblock type.AsyncExecutions<List<Object>> command()
AsyncExecutions<Long> commandCount()
AsyncExecutions<List<Object>> commandInfo(String... commands)
commands
- the commands to query for.AsyncExecutions<List<Object>> commandInfo(CommandType... commands)
commands
- the commands to query for.AsyncExecutions<Map<String,String>> configGet(String parameter)
parameter
- name of the parameter.AsyncExecutions<Map<String,String>> configGet(String... parameters)
parameters
- patterns names of Redis server's configuration.AsyncExecutions<String> configResetstat()
OK
.AsyncExecutions<String> configRewrite()
OK
when the configuration was rewritten properly. Otherwise an error is
returned.AsyncExecutions<String> configSet(String parameter, String value)
parameter
- the parameter name.value
- the parameter value.OK
when the configuration was set properly. Otherwise an error is returned.AsyncExecutions<String> configSet(Map<String,String> kvs)
kvs
- the parameter name and value.OK
when the configuration was set properly. Otherwise an error is returned.AsyncExecutions<Long> dbsize()
AsyncExecutions<String> debugCrashAndRecover(Long delay)
delay
- optional delay in milliseconds.AsyncExecutions<String> debugHtstats(int db)
db
- the database number.AsyncExecutions<String> debugObject(K key)
key
- the key.AsyncExecutions<String> debugReload()
AsyncExecutions<String> debugRestart(Long delay)
delay
- optional delay in milliseconds.AsyncExecutions<String> debugSdslen(K key)
key
- the key.AsyncExecutions<String> flushall()
AsyncExecutions<String> flushall(FlushMode flushMode)
FlushMode
.flushMode
- the flush mode (sync/async).@Deprecated AsyncExecutions<String> flushallAsync()
flushall(FlushMode)
instead.AsyncExecutions<String> flushdb()
AsyncExecutions<String> flushdb(FlushMode flushMode)
FlushMode
.flushMode
- the flush mode (sync/async).@Deprecated AsyncExecutions<String> flushdbAsync()
flushdb(FlushMode)
instead.AsyncExecutions<String> info()
AsyncExecutions<String> info(String section)
section
- the section type: string.AsyncExecutions<Date> lastsave()
AsyncExecutions<Long> memoryUsage(K key)
AsyncExecutions<String> replicaof(String host, int port)
host
- the host type: string.port
- the port type: string.AsyncExecutions<String> replicaofNoOne()
AsyncExecutions<String> save()
AsyncExecutions<String> slaveof(String host, int port)
replicaof(String, int)
instead.host
- the host type: string.port
- the port type: string.AsyncExecutions<String> slaveofNoOne()
replicaofNoOne()
instead.AsyncExecutions<List<Object>> slowlogGet()
AsyncExecutions<List<Object>> slowlogGet(int count)
count
- the count.AsyncExecutions<Long> slowlogLen()
AsyncExecutions<String> slowlogReset()
AsyncExecutions<List<V>> time()
Copyright © 2023 lettuce.io. All rights reserved.