程序包 com.cdkjframework.redis.realize

类 ClusterReactiveCommands

java.lang.Object

com.cdkjframework.redis.realize.ClusterReactiveCommands

所有已实现的接口:

io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisHLLReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>, io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>, io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>, io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

public class ClusterReactiveCommands
extends Object
implements io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

构造器概要

构造器

构造器	说明
ClusterReactiveCommands()

方法概要

修饰符和类型	方法	说明
reactor.core.publisher.Mono<Set<io.lettuce.core.AclCategory>>	aclCat()
reactor.core.publisher.Mono<Set<io.lettuce.core.protocol.CommandType>>	aclCat(io.lettuce.core.AclCategory aclCategory)
reactor.core.publisher.Mono<Long>	aclDeluser(String... strings)
reactor.core.publisher.Mono<String>	aclDryRun(String s, io.lettuce.core.protocol.RedisCommand<String,String,?> redisCommand)
reactor.core.publisher.Mono<String>	aclDryRun(String s, String s1, String... strings)
reactor.core.publisher.Mono<String>	aclGenpass()
reactor.core.publisher.Mono<String>	aclGenpass(int i)
reactor.core.publisher.Mono<List<Object>>	aclGetuser(String s)
reactor.core.publisher.Flux<String>	aclList()
reactor.core.publisher.Mono<String>	aclLoad()
reactor.core.publisher.Flux<Map<String,Object>>	aclLog()
reactor.core.publisher.Flux<Map<String,Object>>	aclLog(int i)
reactor.core.publisher.Mono<String>	aclLogReset()
reactor.core.publisher.Mono<String>	aclSave()
reactor.core.publisher.Mono<String>	aclSetuser(String s, io.lettuce.core.AclSetuserArgs aclSetuserArgs)
reactor.core.publisher.Flux<String>	aclUsers()
reactor.core.publisher.Mono<String>	aclWhoami()
reactor.core.publisher.Mono<Long>	append(String key, String value)	Append a value to a key.
reactor.core.publisher.Mono<String>	asking()	The asking command is required after a -ASK redirection.
reactor.core.publisher.Mono<String>	auth(CharSequence charSequence)
reactor.core.publisher.Mono<String>	auth(String s, CharSequence charSequence)
reactor.core.publisher.Mono<String>	bgrewriteaof()	Asynchronously rewrite the append-only file.
reactor.core.publisher.Mono<String>	bgsave()	Asynchronously save the dataset to disk.
reactor.core.publisher.Mono<Long>	bitcount(String key)	Count set bits in a string.
reactor.core.publisher.Mono<Long>	bitcount(String key, long start, long end)	Count set bits in a string.
reactor.core.publisher.Flux<io.lettuce.core.Value<Long>>	bitfield(String key, io.lettuce.core.BitFieldArgs bitFieldArgs)	Execute BITFIELD with its subcommands.
reactor.core.publisher.Mono<Long>	bitopAnd(String destination, String... keys)	Perform bitwise AND between strings.
reactor.core.publisher.Mono<Long>	bitopNot(String destination, String source)	Perform bitwise NOT between strings.
reactor.core.publisher.Mono<Long>	bitopOr(String destination, String... keys)	Perform bitwise OR between strings.
reactor.core.publisher.Mono<Long>	bitopXor(String destination, String... keys)	Perform bitwise XOR between strings.
reactor.core.publisher.Mono<Long>	bitpos(String key, boolean state)	Find first bit set or clear in a string.
reactor.core.publisher.Mono<Long>	bitpos(String key, boolean state, long start)	Find first bit set or clear in a string.
reactor.core.publisher.Mono<Long>	bitpos(String key, boolean state, long start, long end)	Find first bit set or clear in a string.
reactor.core.publisher.Mono<String>	blmove(String s, String k1, io.lettuce.core.LMoveArgs lMoveArgs, double v)
reactor.core.publisher.Mono<String>	blmove(String s, String k1, io.lettuce.core.LMoveArgs lMoveArgs, long l)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<String>>>	blmpop(double v, io.lettuce.core.LMPopArgs lmPopArgs, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<String>>>	blmpop(long l, io.lettuce.core.LMPopArgs lmPopArgs, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>>	blpop(double v, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>>	blpop(long timeout, String... keys)	Remove and get the first element in a list, or block until one is available.
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>>	brpop(double v, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>>	brpop(long timeout, String... keys)	Remove and get the last element in a list, or block until one is available.
reactor.core.publisher.Mono<String>	brpoplpush(double v, String s, String k1)
reactor.core.publisher.Mono<String>	brpoplpush(long timeout, String source, String destination)	Pop a value from a list, push it to another list and return it; or block until one is available.
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<io.lettuce.core.ScoredValue<String>>>>	bzmpop(double v, int i, io.lettuce.core.ZPopArgs zPopArgs, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>>	bzmpop(double v, io.lettuce.core.ZPopArgs zPopArgs, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<io.lettuce.core.ScoredValue<String>>>>	bzmpop(long l, long l1, io.lettuce.core.ZPopArgs zPopArgs, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>>	bzmpop(long l, io.lettuce.core.ZPopArgs zPopArgs, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>>	bzpopmax(double v, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>>	bzpopmax(long timeout, String... keys)	Removes and returns a member with the highest scores in the sorted set stored at one of the keys.
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>>	bzpopmin(double v, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>>	bzpopmin(long timeout, String... keys)	Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
reactor.core.publisher.Mono<String>	clientCaching(boolean b)
reactor.core.publisher.Mono<String>	clientGetname()	Get the current connection name.
reactor.core.publisher.Mono<Long>	clientGetredir()
reactor.core.publisher.Mono<Long>	clientId()	Get the id of the current connection.
reactor.core.publisher.Mono<String>	clientInfo()
reactor.core.publisher.Mono<Long>	clientKill(io.lettuce.core.KillArgs killArgs)	Kill connections of clients which are filtered by killArgs.
reactor.core.publisher.Mono<String>	clientKill(String addr)	Kill the connection of a client identified by ip:port.
reactor.core.publisher.Mono<String>	clientList()	Get the list of client connections.
reactor.core.publisher.Mono<String>	clientList(io.lettuce.core.ClientListArgs clientListArgs)
reactor.core.publisher.Mono<String>	clientNoEvict(boolean b)
reactor.core.publisher.Mono<String>	clientPause(long timeout)	Stop processing commands from clients for some time.
reactor.core.publisher.Mono<String>	clientSetinfo(String s, String s1)
reactor.core.publisher.Mono<String>	clientSetname(String name)	Set the current connection name on all cluster nodes with pipelining.
reactor.core.publisher.Mono<String>	clientTracking(io.lettuce.core.TrackingArgs trackingArgs)
reactor.core.publisher.Mono<Long>	clientUnblock(long id, io.lettuce.core.UnblockType type)	Unblock the specified blocked client.
reactor.core.publisher.Mono<String>	clusterAddSlots(int... slots)	Adds slots to the cluster node.
reactor.core.publisher.Mono<String>	clusterAddSlotsRange(io.lettuce.core.Range<Integer>... ranges)
reactor.core.publisher.Mono<String>	clusterBumpepoch()	Generate a new config epoch, incrementing the current epoch, assign the new epoch to this node, WITHOUT any consensus and persist the configuration on disk before sending packets with the new configuration.
reactor.core.publisher.Mono<Long>	clusterCountFailureReports(String nodeId)	Returns the number of failure reports for the specified node.
reactor.core.publisher.Mono<Long>	clusterCountKeysInSlot(int slot)	Returns the number of keys in the specified Redis Cluster hash slot.
reactor.core.publisher.Mono<String>	clusterDelSlots(int... slots)	Removes slots from the cluster node.
reactor.core.publisher.Mono<String>	clusterDelSlotsRange(io.lettuce.core.Range<Integer>... ranges)
reactor.core.publisher.Mono<String>	clusterFailover(boolean force)	Failover a cluster node.
reactor.core.publisher.Mono<String>	clusterFailover(boolean b, boolean b1)
reactor.core.publisher.Mono<String>	clusterFlushslots()	Delete all the slots associated with the specified node.
reactor.core.publisher.Mono<String>	clusterForget(String nodeId)	Blacklist and remove the cluster node from the cluster.
reactor.core.publisher.Flux<String>	clusterGetKeysInSlot(int slot, int count)	Retrieve the list of keys within the slot.
reactor.core.publisher.Mono<String>	clusterInfo()	Get information and statistics about the cluster viewed by the current node.
reactor.core.publisher.Mono<Long>	clusterKeyslot(String key)	Returns an integer identifying the hash slot the specified key hashes to.
reactor.core.publisher.Mono<String>	clusterMeet(String ip, int port)	Meet another cluster node to include the node into the cluster.
reactor.core.publisher.Mono<String>	clusterMyId()	Obtain the nodeId for the currently connected node.
reactor.core.publisher.Mono<String>	clusterNodes()	Obtain details about all cluster nodes.
reactor.core.publisher.Flux<String>	clusterReplicas(String s)
reactor.core.publisher.Mono<String>	clusterReplicate(String nodeId)	Turn this node into a replica of the node with the id nodeId.
reactor.core.publisher.Mono<String>	clusterReset(boolean hard)	Reset a node performing a soft or hard reset: All other nodes are forgotten All the assigned / open slots are released If the node is a replica, it turns into a master Only for hard reset: a new Node ID is generated Only for hard reset: currentEpoch and configEpoch are set to 0 The new configuration is saved and the cluster state updated If the node was a replica, the whole data set is flushed away
reactor.core.publisher.Mono<String>	clusterSaveconfig()	Forces a node to save the nodes.conf configuration on disk.
reactor.core.publisher.Mono<String>	clusterSetConfigEpoch(long configEpoch)	This command sets a specific config epoch in a fresh node.
reactor.core.publisher.Mono<String>	clusterSetSlotImporting(int slot, String nodeId)	Flag a slot as IMPORTING (incoming) from the node specified in nodeId.
reactor.core.publisher.Mono<String>	clusterSetSlotMigrating(int slot, String nodeId)	Flag a slot as MIGRATING (outgoing) towards the node specified in nodeId.
reactor.core.publisher.Mono<String>	clusterSetSlotNode(int slot, String nodeId)	Assign a slot to a node.
reactor.core.publisher.Mono<String>	clusterSetSlotStable(int slot)	Clears migrating / importing state from the slot.
reactor.core.publisher.Mono<List<Object>>	clusterShards()
reactor.core.publisher.Flux<String>	clusterSlaves(String nodeId)	已过时。
reactor.core.publisher.Flux<Object>	clusterSlots()	Get array of cluster slots to node mappings.
reactor.core.publisher.Flux<Object>	command()	Returns an array reply of details about all Redis commands.
reactor.core.publisher.Mono<Long>	commandCount()	Get total number of Redis commands.
reactor.core.publisher.Flux<Object>	commandInfo(io.lettuce.core.protocol.CommandType... commands)	Returns an array reply of details about the requested commands.
reactor.core.publisher.Flux<Object>	commandInfo(String... commands)	Returns an array reply of details about the requested commands.
reactor.core.publisher.Mono<Map<String,String>>	configGet(String parameter)	Get the value of a configuration parameter.
reactor.core.publisher.Mono<Map<String,String>>	configGet(String... strings)
reactor.core.publisher.Mono<String>	configResetstat()	Reset the stats returned by INFO.
reactor.core.publisher.Mono<String>	configRewrite()	Rewrite the configuration file with the in memory configuration.
reactor.core.publisher.Mono<String>	configSet(String parameter, String value)	Set a configuration parameter to the given value.
reactor.core.publisher.Mono<String>	configSet(Map<String,String> map)
reactor.core.publisher.Mono<Boolean>	copy(String s, String k1)
reactor.core.publisher.Mono<Boolean>	copy(String s, String k1, io.lettuce.core.CopyArgs copyArgs)
reactor.core.publisher.Mono<Long>	dbsize()	Return the number of keys in the selected database on all cluster masters.
reactor.core.publisher.Mono<String>	debugCrashAndRecover(Long delay)	Crash and recover.
reactor.core.publisher.Mono<String>	debugHtstats(int db)	Get debugging information about the internal hash-table state.
reactor.core.publisher.Mono<String>	debugObject(String key)	Get debugging information about a key.
reactor.core.publisher.Mono<Void>	debugOom()	Make the server crash: Out of memory.
reactor.core.publisher.Mono<String>	debugReload()	Save RDB, clear the database and reload RDB.
reactor.core.publisher.Mono<String>	debugRestart(Long delay)	Restart the server gracefully.
reactor.core.publisher.Mono<String>	debugSdslen(String key)	Get debugging information about the internal SDS length.
reactor.core.publisher.Mono<Void>	debugSegfault()	Make the server crash: Invalid pointer access.
reactor.core.publisher.Mono<Long>	decr(String key)	Decrement the integer value of a key by one.
reactor.core.publisher.Mono<Long>	decrby(String key, long amount)	Decrement the integer value of a key by the given number.
reactor.core.publisher.Mono<Long>	del(String... keys)	Delete one or more keys with pipelining.
String	digest(byte[] bytes)
String	digest(String script)	Create a SHA1 digest from a Lua script.
<T> reactor.core.publisher.Flux<T>	dispatch(io.lettuce.core.protocol.ProtocolKeyword type, io.lettuce.core.output.CommandOutput<String,String,?> output)	Dispatch a command to the Redis Server.
<T> reactor.core.publisher.Flux<T>	dispatch(io.lettuce.core.protocol.ProtocolKeyword type, io.lettuce.core.output.CommandOutput<String,String,?> output, io.lettuce.core.protocol.CommandArgs<String,String> args)	Dispatch a command to the Redis Server.
reactor.core.publisher.Mono<byte[]>	dump(String key)	Return a serialized version of the value stored at the specified key.
reactor.core.publisher.Mono<String>	echo(String msg)	Echo the given string.
<T> reactor.core.publisher.Flux<T>	eval(byte[] bytes, io.lettuce.core.ScriptOutputType scriptOutputType, String... strings)
<T> reactor.core.publisher.Flux<T>	eval(byte[] bytes, io.lettuce.core.ScriptOutputType scriptOutputType, String[] strings, String... strings2)
<T> reactor.core.publisher.Flux<T>	eval(String script, io.lettuce.core.ScriptOutputType type, String... keys)	Execute a Lua script server side.
<T> reactor.core.publisher.Flux<T>	eval(String script, io.lettuce.core.ScriptOutputType type, String[] keys, String... values)	Execute a Lua script server side.
<T> reactor.core.publisher.Flux<T>	evalReadOnly(byte[] bytes, io.lettuce.core.ScriptOutputType scriptOutputType, String[] strings, String... strings2)
<T> reactor.core.publisher.Flux<T>	evalsha(String digest, io.lettuce.core.ScriptOutputType type, String... keys)	Evaluates a script cached on the server side by its SHA1 digest.
<T> reactor.core.publisher.Flux<T>	evalsha(String digest, io.lettuce.core.ScriptOutputType type, String[] keys, String... values)	Execute a Lua script server side.
<T> reactor.core.publisher.Flux<T>	evalshaReadOnly(String s, io.lettuce.core.ScriptOutputType scriptOutputType, String[] strings, String... strings2)
reactor.core.publisher.Mono<Long>	exists(String... keys)	Determine how many keys exist with pipelining.
reactor.core.publisher.Mono<Boolean>	expire(String key, long seconds)	Set a key's time to live in seconds.
reactor.core.publisher.Mono<Boolean>	expire(String s, long l, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Boolean>	expire(String s, Duration duration)
reactor.core.publisher.Mono<Boolean>	expire(String s, Duration duration, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Boolean>	expireat(String key, long timestamp)	Set the expiration for a key as a UNIX timestamp.
reactor.core.publisher.Mono<Boolean>	expireat(String s, long l, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Boolean>	expireat(String s, Instant instant)
reactor.core.publisher.Mono<Boolean>	expireat(String s, Instant instant, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Boolean>	expireat(String key, Date timestamp)	Set the expiration for a key as a UNIX timestamp.
reactor.core.publisher.Mono<Boolean>	expireat(String s, Date date, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Long>	expiretime(String s)
<T> reactor.core.publisher.Flux<T>	fcall(String s, io.lettuce.core.ScriptOutputType scriptOutputType, String... strings)
<T> reactor.core.publisher.Flux<T>	fcall(String s, io.lettuce.core.ScriptOutputType scriptOutputType, String[] strings, String... strings2)
<T> reactor.core.publisher.Flux<T>	fcallReadOnly(String s, io.lettuce.core.ScriptOutputType scriptOutputType, String... strings)
<T> reactor.core.publisher.Flux<T>	fcallReadOnly(String s, io.lettuce.core.ScriptOutputType scriptOutputType, String[] strings, String... strings2)
reactor.core.publisher.Mono<String>	flushall()	Remove all keys from all databases on all cluster masters with pipelining.
reactor.core.publisher.Mono<String>	flushall(io.lettuce.core.FlushMode flushMode)
reactor.core.publisher.Mono<String>	flushallAsync()	Remove all keys asynchronously from all databases on all cluster upstream nodes with pipelining.
void	flushCommands()	已过时。
reactor.core.publisher.Mono<String>	flushdb()	Remove all keys from the current database on all cluster masters with pipelining.
reactor.core.publisher.Mono<String>	flushdb(io.lettuce.core.FlushMode flushMode)
reactor.core.publisher.Mono<String>	flushdbAsync()	已过时。
reactor.core.publisher.Mono<byte[]>	functionDump()
reactor.core.publisher.Mono<String>	functionFlush(io.lettuce.core.FlushMode flushMode)
reactor.core.publisher.Mono<String>	functionKill()
reactor.core.publisher.Flux<Map<String,Object>>	functionList()
reactor.core.publisher.Flux<Map<String,Object>>	functionList(String s)
reactor.core.publisher.Mono<String>	functionLoad(String s)
reactor.core.publisher.Mono<String>	functionLoad(String s, boolean b)
reactor.core.publisher.Mono<String>	functionRestore(byte[] bytes)
reactor.core.publisher.Mono<String>	functionRestore(byte[] bytes, io.lettuce.core.FunctionRestoreMode functionRestoreMode)
reactor.core.publisher.Mono<Long>	geoadd(String key, double longitude, double latitude, String member)	Single geo add.
reactor.core.publisher.Mono<Long>	geoadd(String s, double v, double v1, String v2, io.lettuce.core.GeoAddArgs geoAddArgs)
reactor.core.publisher.Mono<Long>	geoadd(String s, io.lettuce.core.GeoAddArgs geoAddArgs, io.lettuce.core.GeoValue<String>... geoValues)
reactor.core.publisher.Mono<Long>	geoadd(String s, io.lettuce.core.GeoAddArgs geoAddArgs, Object... objects)
reactor.core.publisher.Mono<Long>	geoadd(String s, io.lettuce.core.GeoValue<String>... geoValues)
reactor.core.publisher.Mono<Long>	geoadd(String key, Object... lngLatMember)	Multi geo add.
reactor.core.publisher.Mono<Double>	geodist(String key, String from, String to, io.lettuce.core.GeoArgs.Unit unit)	Retrieve distance between points from and to.
reactor.core.publisher.Flux<io.lettuce.core.Value<String>>	geohash(String key, String... members)	Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a geospatial index.
reactor.core.publisher.Flux<io.lettuce.core.Value<io.lettuce.core.GeoCoordinates>>	geopos(String key, String... members)	Get geo coordinates for the members.
reactor.core.publisher.Flux<String>	georadius(String key, double longitude, double latitude, double distance, io.lettuce.core.GeoArgs.Unit unit)	Retrieve members selected by distance with the center of longitude and latitude.
reactor.core.publisher.Flux<io.lettuce.core.GeoWithin<String>>	georadius(String key, double longitude, double latitude, double distance, io.lettuce.core.GeoArgs.Unit unit, io.lettuce.core.GeoArgs geoArgs)	Retrieve members selected by distance with the center of longitude and latitude.
reactor.core.publisher.Mono<Long>	georadius(String key, double longitude, double latitude, double distance, io.lettuce.core.GeoArgs.Unit unit, io.lettuce.core.GeoRadiusStoreArgs<String> geoRadiusStoreArgs)	Perform a {@link #(Object, double, double, double, GeoArgs.Unit, GeoArgs)} query and store the results in a sorted set.
reactor.core.publisher.Flux<String>	georadiusbymember(String key, String member, double distance, io.lettuce.core.GeoArgs.Unit unit)	Retrieve members selected by distance with the center of member.
reactor.core.publisher.Flux<io.lettuce.core.GeoWithin<String>>	georadiusbymember(String key, String member, double distance, io.lettuce.core.GeoArgs.Unit unit, io.lettuce.core.GeoArgs geoArgs)	Retrieve members selected by distance with the center of member.
reactor.core.publisher.Mono<Long>	georadiusbymember(String key, String member, double distance, io.lettuce.core.GeoArgs.Unit unit, io.lettuce.core.GeoRadiusStoreArgs<String> geoRadiusStoreArgs)	Perform a {@link #(Object, Object, double, GeoArgs.Unit, GeoArgs)} query and store the results in a sorted set.
reactor.core.publisher.Flux<String>	geosearch(String s, io.lettuce.core.GeoSearch.GeoRef<String> geoRef, io.lettuce.core.GeoSearch.GeoPredicate geoPredicate)
reactor.core.publisher.Flux<io.lettuce.core.GeoWithin<String>>	geosearch(String s, io.lettuce.core.GeoSearch.GeoRef<String> geoRef, io.lettuce.core.GeoSearch.GeoPredicate geoPredicate, io.lettuce.core.GeoArgs geoArgs)
reactor.core.publisher.Mono<Long>	geosearchstore(String s, String k1, io.lettuce.core.GeoSearch.GeoRef<String> geoRef, io.lettuce.core.GeoSearch.GeoPredicate geoPredicate, io.lettuce.core.GeoArgs geoArgs, boolean b)
reactor.core.publisher.Mono<String>	get(String key)	Get the value of a key.
reactor.core.publisher.Mono<Long>	getbit(String key, long offset)	Returns the bit value at offset in the string value stored at key.
io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>	getConnection(String nodeId)	Retrieve a connection to the specified cluster node using the nodeId.
io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>	getConnection(String host, int port)	Retrieve a connection to the specified cluster node using host and port.
reactor.core.publisher.Mono<String>	getdel(String s)
reactor.core.publisher.Mono<String>	getex(String s, io.lettuce.core.GetExArgs getExArgs)
reactor.core.publisher.Mono<String>	getrange(String key, long start, long end)	Get a substring of the string stored at a key.
reactor.core.publisher.Mono<String>	getset(String key, String value)	Set the string value of a key and return its old value.
io.lettuce.core.cluster.api.StatefulRedisClusterConnection<String,String>	getStatefulConnection()	已过时。
reactor.core.publisher.Mono<Long>	hdel(String key, String... fields)	Delete one or more hash fields.
reactor.core.publisher.Mono<Boolean>	hexists(String key, String field)	Determine if a hash field exists.
reactor.core.publisher.Mono<String>	hget(String key, String field)	Get the value of a hash field.
reactor.core.publisher.Mono<Long>	hgetall(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel, String key)	Stream over all the fields and values in a hash.
reactor.core.publisher.Flux<io.lettuce.core.KeyValue<String,String>>	hgetall(String s)
reactor.core.publisher.Mono<Long>	hincrby(String key, String field, long amount)	Increment the integer value of a hash field by the given number.
reactor.core.publisher.Mono<Double>	hincrbyfloat(String key, String field, double amount)	Increment the float value of a hash field by the given amount.
reactor.core.publisher.Mono<Long>	hkeys(io.lettuce.core.output.KeyStreamingChannel<String> channel, String key)	Stream over all the fields in a hash.
reactor.core.publisher.Flux<String>	hkeys(String key)	Get all the fields in a hash.
reactor.core.publisher.Mono<Long>	hlen(String key)	Get the number of fields in a hash.
reactor.core.publisher.Mono<Long>	hmget(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel, String key, String... fields)	Stream over the values of all the given hash fields.
reactor.core.publisher.Flux<io.lettuce.core.KeyValue<String,String>>	hmget(String key, String... fields)	Get the values of all the given hash fields.
reactor.core.publisher.Mono<String>	hmset(String key, Map<String,String> map)	Set multiple hash fields to multiple values.
reactor.core.publisher.Mono<String>	hrandfield(String s)
reactor.core.publisher.Flux<String>	hrandfield(String s, long l)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>>	hrandfieldWithvalues(String s)
reactor.core.publisher.Flux<io.lettuce.core.KeyValue<String,String>>	hrandfieldWithvalues(String s, long l)
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	hscan(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel, String key)	Incrementally iterate hash fields and associated values.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	hscan(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel, String key, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate hash fields and associated values.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	hscan(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel, String key, io.lettuce.core.ScanCursor scanCursor)	Incrementally iterate hash fields and associated values.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	hscan(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel, String key, io.lettuce.core.ScanCursor scanCursor, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate hash fields and associated values.
reactor.core.publisher.Mono<io.lettuce.core.MapScanCursor<String,String>>	hscan(String key)	Incrementally iterate hash fields and associated values.
reactor.core.publisher.Mono<io.lettuce.core.MapScanCursor<String,String>>	hscan(String key, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate hash fields and associated values.
reactor.core.publisher.Mono<io.lettuce.core.MapScanCursor<String,String>>	hscan(String key, io.lettuce.core.ScanCursor scanCursor)	Incrementally iterate hash fields and associated values.
reactor.core.publisher.Mono<io.lettuce.core.MapScanCursor<String,String>>	hscan(String key, io.lettuce.core.ScanCursor scanCursor, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate hash fields and associated values.
reactor.core.publisher.Mono<Boolean>	hset(String key, String field, String value)	Set the string value of a hash field.
reactor.core.publisher.Mono<Long>	hset(String key, Map<String,String> map)	Set multiple hash fields to multiple values.
reactor.core.publisher.Mono<Boolean>	hsetnx(String key, String field, String value)	Set the value of a hash field, only if the field does not exist.
reactor.core.publisher.Mono<Long>	hstrlen(String key, String field)	Get the string length of the field value in a hash.
reactor.core.publisher.Mono<Long>	hvals(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key)	Stream over all the values in a hash.
reactor.core.publisher.Flux<String>	hvals(String key)	Get all the values in a hash.
reactor.core.publisher.Mono<Long>	incr(String key)	Increment the integer value of a key by one.
reactor.core.publisher.Mono<Long>	incrby(String key, long amount)	Increment the integer value of a key by the given amount.
reactor.core.publisher.Mono<Double>	incrbyfloat(String key, double amount)	Increment the float value of a key by the given amount.
reactor.core.publisher.Mono<String>	info()	Get information and statistics about the server.
reactor.core.publisher.Mono<String>	info(String section)	Get information and statistics about the server.
boolean	isOpen()	已过时。
reactor.core.publisher.Mono<Long>	keys(io.lettuce.core.output.KeyStreamingChannel<String> channel, String pattern)	已过时。
reactor.core.publisher.Flux<String>	keys(String pattern)	Find all keys matching the given pattern on all cluster masters.
reactor.core.publisher.Mono<Date>	lastsave()	Get the UNIX time stamp of the last successful save to disk.
reactor.core.publisher.Mono<String>	lindex(String key, long index)	Get an element from a list by its index.
reactor.core.publisher.Mono<Long>	linsert(String key, boolean before, String pivot, String value)	Insert an element before or after another element in a list.
reactor.core.publisher.Mono<Long>	llen(String key)	Get the length of a list.
reactor.core.publisher.Mono<String>	lmove(String s, String k1, io.lettuce.core.LMoveArgs lMoveArgs)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<String>>>	lmpop(io.lettuce.core.LMPopArgs lmPopArgs, String... strings)
reactor.core.publisher.Mono<String>	lpop(String key)	Remove and get the first element in a list.
reactor.core.publisher.Flux<String>	lpop(String s, long l)
reactor.core.publisher.Mono<Long>	lpos(String key, String value)	Return the index of matching elements inside a Redis list.
reactor.core.publisher.Flux<Long>	lpos(String key, String value, int count)	Return the index of matching elements inside a Redis list using the COUNT option.
reactor.core.publisher.Flux<Long>	lpos(String key, String value, int count, io.lettuce.core.LPosArgs args)	Return the index of matching elements inside a Redis list using the COUNT option.
reactor.core.publisher.Mono<Long>	lpos(String key, String value, io.lettuce.core.LPosArgs args)	Return the index of matching elements inside a Redis list.
reactor.core.publisher.Mono<Long>	lpush(String key, String... values)	Prepend one or multiple values to a list.
reactor.core.publisher.Mono<Long>	lpushx(String key, String... values)	Prepend values to a list, only if the list exists.
reactor.core.publisher.Mono<Long>	lrange(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, long start, long stop)	Get a range of elements from a list.
reactor.core.publisher.Flux<String>	lrange(String key, long start, long stop)	Get a range of elements from a list.
reactor.core.publisher.Mono<Long>	lrem(String key, long count, String value)	Remove elements from a list.
reactor.core.publisher.Mono<String>	lset(String key, long index, String value)	Set the value of an element in a list by its index.
reactor.core.publisher.Mono<String>	ltrim(String key, long start, long stop)	Trim a list to the specified range.
reactor.core.publisher.Mono<Long>	memoryUsage(String key)	Reports the number of bytes that a key and its value require to be stored in RAM.
reactor.core.publisher.Mono<Long>	mget(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel, String... keys)	已过时。
reactor.core.publisher.Flux<io.lettuce.core.KeyValue<String,String>>	mget(String... keys)	Get the values of all the given keys with pipelining.
reactor.core.publisher.Mono<String>	migrate(String host, int port, int db, long timeout, io.lettuce.core.MigrateArgs<String> migrateArgs)	Atomically transfer one or more keys from a Redis instance to another one.
reactor.core.publisher.Mono<String>	migrate(String host, int port, String key, int db, long timeout)	Atomically transfer a key from a Redis instance to another one.
reactor.core.publisher.Mono<Boolean>	move(String key, int db)	Move a key to another database.
reactor.core.publisher.Mono<String>	mset(Map<String,String> map)	Set multiple keys to multiple values with pipelining.
reactor.core.publisher.Mono<Boolean>	msetnx(Map<String,String> map)	Set multiple keys to multiple values, only if none of the keys exist with pipelining.
reactor.core.publisher.Mono<String>	objectEncoding(String key)	returns the kind of internal representation used in order to store the value associated with a key.
reactor.core.publisher.Mono<Long>	objectFreq(String s)
reactor.core.publisher.Mono<Long>	objectIdletime(String key)	returns the number of seconds since the object stored at the specified key is idle (not requested by read or write operations).
reactor.core.publisher.Mono<Long>	objectRefcount(String key)	returns the number of references of the value associated with the specified key.
reactor.core.publisher.Mono<Boolean>	persist(String key)	Remove the expiration from a key.
reactor.core.publisher.Mono<Boolean>	pexpire(String key, long milliseconds)	Set a key's time to live in milliseconds.
reactor.core.publisher.Mono<Boolean>	pexpire(String s, long l, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Boolean>	pexpire(String s, Duration duration)
reactor.core.publisher.Mono<Boolean>	pexpire(String s, Duration duration, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Boolean>	pexpireat(String key, long timestamp)	Set the expiration for a key as a UNIX timestamp specified in milliseconds.
reactor.core.publisher.Mono<Boolean>	pexpireat(String s, long l, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Boolean>	pexpireat(String s, Instant instant)
reactor.core.publisher.Mono<Boolean>	pexpireat(String s, Instant instant, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Boolean>	pexpireat(String key, Date timestamp)	Set the expiration for a key as a UNIX timestamp specified in milliseconds.
reactor.core.publisher.Mono<Boolean>	pexpireat(String s, Date date, io.lettuce.core.ExpireArgs expireArgs)
reactor.core.publisher.Mono<Long>	pexpiretime(String s)
reactor.core.publisher.Mono<Long>	pfadd(String key, String... values)	Adds the specified elements to the specified HyperLogLog.
reactor.core.publisher.Mono<Long>	pfcount(String... keys)	Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).
reactor.core.publisher.Mono<String>	pfmerge(String destkey, String... sourcekeys)	Merge N different HyperLogLogs into a single one.
reactor.core.publisher.Mono<String>	ping()	Ping the server.
reactor.core.publisher.Mono<String>	psetex(String key, long milliseconds, String value)	Set the value and expiration in milliseconds of a key.
reactor.core.publisher.Mono<Long>	pttl(String key)	Get the time to live for a key in milliseconds.
reactor.core.publisher.Mono<Long>	publish(String channel, String message)	Post a message to a channel.
reactor.core.publisher.Flux<String>	pubsubChannels()	Lists the currently *active channels*.
reactor.core.publisher.Flux<String>	pubsubChannels(String channel)	Lists the currently *active channels*.
reactor.core.publisher.Mono<Long>	pubsubNumpat()	Returns the number of subscriptions to patterns.
reactor.core.publisher.Mono<Map<String,Long>>	pubsubNumsub(String... channels)	Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.
reactor.core.publisher.Mono<String>	quit()	Instructs Redis to disconnect the connection.
reactor.core.publisher.Mono<String>	randomkey()	Return a random key from the keyspace on a random master.
reactor.core.publisher.Mono<String>	readOnly()	Tells a Redis cluster replica node that the client is ok reading possibly stale data and is not interested in running write queries.
reactor.core.publisher.Mono<String>	readWrite()	Resets readOnly flag.
reactor.core.publisher.Mono<String>	rename(String key, String newKey)	Rename a key.
reactor.core.publisher.Mono<Boolean>	renamenx(String key, String newKey)	Rename a key, only if the new key does not exist.
reactor.core.publisher.Mono<String>	replicaof(String s, int i)
reactor.core.publisher.Mono<String>	replicaofNoOne()
void	reset()	已过时。
reactor.core.publisher.Mono<String>	restore(String key, byte[] value, io.lettuce.core.RestoreArgs args)	Create a key using the provided serialized value, previously obtained using DUMP.
reactor.core.publisher.Mono<String>	restore(String key, long ttl, byte[] value)	Create a key using the provided serialized value, previously obtained using DUMP.
reactor.core.publisher.Flux<Object>	role()	Return the role of the instance in the context of replication.
reactor.core.publisher.Mono<String>	rpop(String key)	Remove and get the last element in a list.
reactor.core.publisher.Flux<String>	rpop(String s, long l)
reactor.core.publisher.Mono<String>	rpoplpush(String source, String destination)	Remove the last element in a list, append it to another list and return it.
reactor.core.publisher.Mono<Long>	rpush(String key, String... values)	Append one or multiple values to a list.
reactor.core.publisher.Mono<Long>	rpushx(String key, String... values)	Append values to a list, only if the list exists.
reactor.core.publisher.Mono<Long>	sadd(String key, String... members)	Add one or more members to a set.
reactor.core.publisher.Mono<String>	save()	Synchronously save the dataset to disk.
reactor.core.publisher.Mono<io.lettuce.core.KeyScanCursor<String>>	scan()	Incrementally iterate the keys space over the whole Cluster.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	scan(io.lettuce.core.output.KeyStreamingChannel<String> channel)	Incrementally iterate the keys space over the whole Cluster.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	scan(io.lettuce.core.output.KeyStreamingChannel<String> channel, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate the keys space over the whole Cluster.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	scan(io.lettuce.core.output.KeyStreamingChannel<String> channel, io.lettuce.core.ScanCursor scanCursor)	Incrementally iterate the keys space over the whole Cluster.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	scan(io.lettuce.core.output.KeyStreamingChannel<String> channel, io.lettuce.core.ScanCursor scanCursor, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate the keys space over the whole Cluster.
reactor.core.publisher.Mono<io.lettuce.core.KeyScanCursor<String>>	scan(io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate the keys space over the whole Cluster.
reactor.core.publisher.Mono<io.lettuce.core.KeyScanCursor<String>>	scan(io.lettuce.core.ScanCursor scanCursor)	Incrementally iterate the keys space over the whole Cluster.
reactor.core.publisher.Mono<io.lettuce.core.KeyScanCursor<String>>	scan(io.lettuce.core.ScanCursor scanCursor, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate the keys space over the whole Cluster.
reactor.core.publisher.Mono<Long>	scard(String key)	Get the number of members in a set.
reactor.core.publisher.Flux<Boolean>	scriptExists(String... digests)	Check existence of scripts in the script cache.
reactor.core.publisher.Mono<String>	scriptFlush()	Remove all the scripts from the script cache on all cluster nodes.
reactor.core.publisher.Mono<String>	scriptFlush(io.lettuce.core.FlushMode flushMode)
reactor.core.publisher.Mono<String>	scriptKill()	Kill the script currently in execution on all cluster nodes.
reactor.core.publisher.Mono<String>	scriptLoad(byte[] bytes)
reactor.core.publisher.Mono<String>	scriptLoad(String script)	Load the specified Lua script into the script cache on all cluster nodes.
reactor.core.publisher.Mono<Long>	sdiff(io.lettuce.core.output.ValueStreamingChannel<String> channel, String... keys)	Subtract multiple sets.
reactor.core.publisher.Flux<String>	sdiff(String... keys)	Subtract multiple sets.
reactor.core.publisher.Mono<Long>	sdiffstore(String destination, String... keys)	Subtract multiple sets and store the resulting set in a key.
reactor.core.publisher.Mono<String>	set(String key, String value)	Set the string value of a key.
reactor.core.publisher.Mono<String>	set(String key, String value, io.lettuce.core.SetArgs setArgs)	Set the string value of a key.
void	setAutoFlushCommands(boolean autoFlush)	已过时。
reactor.core.publisher.Mono<Long>	setbit(String key, long offset, int value)	Sets or clears the bit at offset in the string value stored at key.
reactor.core.publisher.Mono<String>	setex(String key, long seconds, String value)	Set the value and expiration of a key.
reactor.core.publisher.Mono<String>	setGet(String s, String s2)
reactor.core.publisher.Mono<String>	setGet(String s, String s2, io.lettuce.core.SetArgs setArgs)
reactor.core.publisher.Mono<Boolean>	setnx(String key, String value)	Set the value of a key, only if the key does not exist.
reactor.core.publisher.Mono<Long>	setrange(String key, long offset, String value)	Overwrite part of a string at key starting at the specified offset.
void	setTimeout(Duration timeout)	已过时。
reactor.core.publisher.Mono<Void>	shutdown(boolean save)	Synchronously save the dataset to disk and then shut down all nodes of the cluster.
reactor.core.publisher.Mono<Void>	shutdown(io.lettuce.core.ShutdownArgs shutdownArgs)
reactor.core.publisher.Mono<Long>	sinter(io.lettuce.core.output.ValueStreamingChannel<String> channel, String... keys)	已过时。
reactor.core.publisher.Flux<String>	sinter(String... keys)	Intersect multiple sets.
reactor.core.publisher.Mono<Long>	sintercard(long l, String... strings)
reactor.core.publisher.Mono<Long>	sintercard(String... strings)
reactor.core.publisher.Mono<Long>	sinterstore(String destination, String... keys)	Intersect multiple sets and store the resulting set in a key.
reactor.core.publisher.Mono<Boolean>	sismember(String key, String member)	Determine if a given value is a member of a set.
reactor.core.publisher.Mono<String>	slaveof(String host, int port)	Make the server a replica of another instance, or promote it as master.
reactor.core.publisher.Mono<String>	slaveofNoOne()	Promote server as master.
reactor.core.publisher.Flux<Object>	slowlogGet()	Read the slow log.
reactor.core.publisher.Flux<Object>	slowlogGet(int count)	Read the slow log.
reactor.core.publisher.Mono<Long>	slowlogLen()	Obtaining the current length of the slow log.
reactor.core.publisher.Mono<String>	slowlogReset()	Resetting the slow log.
reactor.core.publisher.Mono<Long>	smembers(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key)	已过时。
reactor.core.publisher.Flux<String>	smembers(String key)	Get all the members in a set.
reactor.core.publisher.Flux<Boolean>	smismember(String s, String... strings)
reactor.core.publisher.Mono<Boolean>	smove(String source, String destination, String member)	Move a member from one set to another.
reactor.core.publisher.Mono<Long>	sort(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key)	已过时。
reactor.core.publisher.Mono<Long>	sort(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, io.lettuce.core.SortArgs sortArgs)	已过时。
reactor.core.publisher.Flux<String>	sort(String key)	Sort the elements in a list, set or sorted set.
reactor.core.publisher.Flux<String>	sort(String key, io.lettuce.core.SortArgs sortArgs)	Sort the elements in a list, set or sorted set.
reactor.core.publisher.Mono<Long>	sortReadOnly(io.lettuce.core.output.ValueStreamingChannel<String> valueStreamingChannel, String s)	已过时。
reactor.core.publisher.Mono<Long>	sortReadOnly(io.lettuce.core.output.ValueStreamingChannel<String> valueStreamingChannel, String s, io.lettuce.core.SortArgs sortArgs)	已过时。
reactor.core.publisher.Flux<String>	sortReadOnly(String s)
reactor.core.publisher.Flux<String>	sortReadOnly(String s, io.lettuce.core.SortArgs sortArgs)
reactor.core.publisher.Mono<Long>	sortStore(String key, io.lettuce.core.SortArgs sortArgs, String destination)	Sort the elements in a list, set or sorted set.
reactor.core.publisher.Mono<String>	spop(String key)	Remove and return a random member from a set.
reactor.core.publisher.Flux<String>	spop(String key, long count)	Remove and return one or multiple random members from a set.
reactor.core.publisher.Mono<Long>	srandmember(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, long count)	已过时。
reactor.core.publisher.Mono<String>	srandmember(String key)	Get one random member from a set.
reactor.core.publisher.Flux<String>	srandmember(String key, long count)	Get one or multiple random members from a set.
reactor.core.publisher.Mono<Long>	srem(String key, String... members)	Remove one or more members from a set.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	sscan(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key)	已过时。
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	sscan(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, io.lettuce.core.ScanArgs scanArgs)	已过时。
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	sscan(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, io.lettuce.core.ScanCursor scanCursor)	已过时。
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	sscan(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, io.lettuce.core.ScanCursor scanCursor, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate Set elements.
reactor.core.publisher.Mono<io.lettuce.core.ValueScanCursor<String>>	sscan(String key)	Incrementally iterate Set elements.
reactor.core.publisher.Mono<io.lettuce.core.ValueScanCursor<String>>	sscan(String key, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate Set elements.
reactor.core.publisher.Mono<io.lettuce.core.ValueScanCursor<String>>	sscan(String key, io.lettuce.core.ScanCursor scanCursor)	Incrementally iterate Set elements.
reactor.core.publisher.Mono<io.lettuce.core.ValueScanCursor<String>>	sscan(String key, io.lettuce.core.ScanCursor scanCursor, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate Set elements.
reactor.core.publisher.Mono<io.lettuce.core.StringMatchResult>	stralgoLcs(io.lettuce.core.StrAlgoArgs strAlgoArgs)	The STRALGO command implements complex algorithms that operate on strings.
reactor.core.publisher.Mono<Long>	strlen(String key)	Get the length of the value stored in a key.
reactor.core.publisher.Mono<Long>	sunion(io.lettuce.core.output.ValueStreamingChannel<String> channel, String... keys)	已过时。
reactor.core.publisher.Flux<String>	sunion(String... keys)	Add multiple sets.
reactor.core.publisher.Mono<Long>	sunionstore(String destination, String... keys)	Add multiple sets and store the resulting set in a key.
reactor.core.publisher.Flux<String>	time()	Return the current server time.
reactor.core.publisher.Mono<Long>	touch(String... keys)	Touch one or more keys with pipelining.
reactor.core.publisher.Mono<Long>	ttl(String key)	Get the time to live for a key.
reactor.core.publisher.Mono<String>	type(String key)	Determine the type stored at key.
reactor.core.publisher.Mono<Long>	unlink(String... keys)	Unlink one or more keys with pipelining.
reactor.core.publisher.Mono<Long>	waitForReplication(int replicas, long timeout)	Wait for replication.
reactor.core.publisher.Mono<Long>	xack(String key, String group, String... messageIds)	Acknowledge one or more messages as processed.
reactor.core.publisher.Mono<String>	xadd(String key, io.lettuce.core.XAddArgs args, Object... keysAndValues)	Append a message to the stream key.
reactor.core.publisher.Mono<String>	xadd(String key, io.lettuce.core.XAddArgs args, Map<String,String> body)	Append a message to the stream key.
reactor.core.publisher.Mono<String>	xadd(String key, Object... keysAndValues)	Append a message to the stream key.
reactor.core.publisher.Mono<String>	xadd(String key, Map<String,String> body)	Append a message to the stream key.
reactor.core.publisher.Mono<io.lettuce.core.models.stream.ClaimedMessages<String,String>>	xautoclaim(String s, io.lettuce.core.XAutoClaimArgs<String> xAutoClaimArgs)
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xclaim(String key, io.lettuce.core.Consumer<String> consumer, long minIdleTime, String... messageIds)	Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xclaim(String key, io.lettuce.core.Consumer<String> consumer, io.lettuce.core.XClaimArgs args, String... messageIds)	Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.
reactor.core.publisher.Mono<Long>	xdel(String key, String... messageIds)	Removes the specified entries from the stream.
reactor.core.publisher.Mono<String>	xgroupCreate(io.lettuce.core.XReadArgs.StreamOffset<String> streamOffset, String group)	Create a consumer group.
reactor.core.publisher.Mono<String>	xgroupCreate(io.lettuce.core.XReadArgs.StreamOffset<String> streamOffset, String group, io.lettuce.core.XGroupCreateArgs args)	Create a consumer group.
reactor.core.publisher.Mono<Boolean>	xgroupCreateconsumer(String s, io.lettuce.core.Consumer<String> consumer)
reactor.core.publisher.Mono<Long>	xgroupDelconsumer(String s, io.lettuce.core.Consumer<String> consumer)
reactor.core.publisher.Mono<Boolean>	xgroupDestroy(String key, String group)	Destroy a consumer group.
reactor.core.publisher.Mono<String>	xgroupSetid(io.lettuce.core.XReadArgs.StreamOffset<String> streamOffset, String group)	Set the current group id.
reactor.core.publisher.Flux<Object>	xinfoConsumers(String key, String group)	Retrieve information about consumer groups of group group and stream at key.
reactor.core.publisher.Flux<Object>	xinfoGroups(String key)	Retrieve information about the stream consumer groups at key.
reactor.core.publisher.Flux<Object>	xinfoStream(String key)	Retrieve information about the stream at key.
reactor.core.publisher.Mono<Long>	xlen(String key)	Get the length of a steam.
reactor.core.publisher.Flux<io.lettuce.core.models.stream.PendingMessage>	xpending(String s, io.lettuce.core.Consumer<String> consumer, io.lettuce.core.Range<String> range, io.lettuce.core.Limit limit)
reactor.core.publisher.Flux<io.lettuce.core.models.stream.PendingMessage>	xpending(String s, io.lettuce.core.XPendingArgs<String> xPendingArgs)
reactor.core.publisher.Mono<io.lettuce.core.models.stream.PendingMessages>	xpending(String s, String k1)
reactor.core.publisher.Flux<io.lettuce.core.models.stream.PendingMessage>	xpending(String s, String k1, io.lettuce.core.Range<String> range, io.lettuce.core.Limit limit)
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xrange(String key, io.lettuce.core.Range<String> range)	Read messages from a stream within a specific Range.
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xrange(String key, io.lettuce.core.Range<String> range, io.lettuce.core.Limit limit)	Read messages from a stream within a specific Range applying a Limit.
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xread(io.lettuce.core.XReadArgs.StreamOffset<String>... streams)	Read messages from one or more StreamOffsets.
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xread(io.lettuce.core.XReadArgs args, io.lettuce.core.XReadArgs.StreamOffset<String>... streams)	Read messages from one or more StreamOffsets.
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xreadgroup(io.lettuce.core.Consumer<String> consumer, io.lettuce.core.XReadArgs.StreamOffset<String>... streams)	Read messages from one or more StreamOffsets using a consumer group.
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xreadgroup(io.lettuce.core.Consumer<String> consumer, io.lettuce.core.XReadArgs args, io.lettuce.core.XReadArgs.StreamOffset<String>... streams)	Read messages from one or more StreamOffsets using a consumer group.
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xrevrange(String key, io.lettuce.core.Range<String> range)	Read messages from a stream within a specific Range in reverse order.
reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>>	xrevrange(String key, io.lettuce.core.Range<String> range, io.lettuce.core.Limit limit)	Read messages from a stream within a specific Range applying a Limit in reverse order.
reactor.core.publisher.Mono<Long>	xtrim(String key, boolean approximateTrimming, long count)	Trims the stream to count elements.
reactor.core.publisher.Mono<Long>	xtrim(String key, long count)	Trims the stream to count elements.
reactor.core.publisher.Mono<Long>	xtrim(String s, io.lettuce.core.XTrimArgs xTrimArgs)
reactor.core.publisher.Mono<Long>	zadd(String key, double score, String member)	Add one or more members to a sorted set, or update its score if it already exists.
reactor.core.publisher.Mono<Long>	zadd(String key, io.lettuce.core.ScoredValue<String>... scoredValues)	Add one or more members to a sorted set, or update its score if it already exists.
reactor.core.publisher.Mono<Long>	zadd(String key, io.lettuce.core.ZAddArgs zAddArgs, double score, String member)	Add one or more members to a sorted set, or update its score if it already exists.
reactor.core.publisher.Mono<Long>	zadd(String key, io.lettuce.core.ZAddArgs zAddArgs, io.lettuce.core.ScoredValue<String>... scoredValues)	Add one or more members to a sorted set, or update its score if it already exists.
reactor.core.publisher.Mono<Long>	zadd(String key, io.lettuce.core.ZAddArgs zAddArgs, Object... scoresAndValues)	Add one or more members to a sorted set, or update its score if it already exists.
reactor.core.publisher.Mono<Long>	zadd(String key, Object... scoresAndValues)	Add one or more members to a sorted set, or update its score if it already exists.
reactor.core.publisher.Mono<Double>	zaddincr(String key, double score, String member)	Add one or more members to a sorted set, or update its score if it already exists applying the INCR option.
reactor.core.publisher.Mono<Double>	zaddincr(String key, io.lettuce.core.ZAddArgs zAddArgs, double score, String member)	Add one or more members to a sorted set, or update its score if it already exists applying the INCR option.
reactor.core.publisher.Mono<Long>	zcard(String key)	Get the number of members in a sorted set.
reactor.core.publisher.Mono<Long>	zcount(String key, double min, double max)	已过时。 Use RedisSortedSetReactiveCommands.zcount(Object, Range).
reactor.core.publisher.Mono<Long>	zcount(String key, io.lettuce.core.Range<? extends Number> range)	Count the members in a sorted set with scores within the given Range.
reactor.core.publisher.Mono<Long>	zcount(String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zcount(Object, Range).
reactor.core.publisher.Flux<String>	zdiff(String... strings)
reactor.core.publisher.Mono<Long>	zdiffstore(String s, String... strings)
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zdiffWithScores(String... strings)
reactor.core.publisher.Mono<Double>	zincrby(String key, double amount, String member)	Increment the score of a member in a sorted set.
reactor.core.publisher.Flux<String>	zinter(io.lettuce.core.ZAggregateArgs zAggregateArgs, String... strings)
reactor.core.publisher.Flux<String>	zinter(String... strings)
reactor.core.publisher.Mono<Long>	zintercard(long l, String... strings)
reactor.core.publisher.Mono<Long>	zintercard(String... strings)
reactor.core.publisher.Mono<Long>	zinterstore(String destination, io.lettuce.core.ZStoreArgs storeArgs, String... keys)	Intersect multiple sorted sets and store the resulting sorted set in a new key.
reactor.core.publisher.Mono<Long>	zinterstore(String destination, String... keys)	Intersect multiple sorted sets and store the resulting sorted set in a new key.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zinterWithScores(io.lettuce.core.ZAggregateArgs zAggregateArgs, String... strings)
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zinterWithScores(String... strings)
reactor.core.publisher.Mono<Long>	zlexcount(String key, io.lettuce.core.Range<? extends String> range)	Count the number of members in a sorted set between a given lexicographical range.
reactor.core.publisher.Mono<Long>	zlexcount(String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zlexcount(Object, Range).
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<io.lettuce.core.ScoredValue<String>>>>	zmpop(int i, io.lettuce.core.ZPopArgs zPopArgs, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>>	zmpop(io.lettuce.core.ZPopArgs zPopArgs, String... strings)
reactor.core.publisher.Mono<List<Double>>	zmscore(String s, String... strings)
reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<String>>	zpopmax(String key)	Removes and returns up to count members with the highest scores in the sorted set stored at key.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zpopmax(String key, long count)	Removes and returns up to count members with the highest scores in the sorted set stored at key.
reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<String>>	zpopmin(String key)	Removes and returns up to count members with the lowest scores in the sorted set stored at key.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zpopmin(String key, long count)	Removes and returns up to count members with the lowest scores in the sorted set stored at key.
reactor.core.publisher.Mono<String>	zrandmember(String s)
reactor.core.publisher.Flux<String>	zrandmember(String s, long l)
reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<String>>	zrandmemberWithScores(String s)
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrandmemberWithScores(String s, long l)
reactor.core.publisher.Mono<Long>	zrange(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, long start, long stop)	已过时。
reactor.core.publisher.Flux<String>	zrange(String key, long start, long stop)	Return a range of members in a sorted set, by index.
reactor.core.publisher.Flux<String>	zrangebylex(String key, io.lettuce.core.Range<? extends String> range)	Return a range of members in a sorted set, by lexicographical range.
reactor.core.publisher.Flux<String>	zrangebylex(String key, io.lettuce.core.Range<? extends String> range, io.lettuce.core.Limit limit)	Return a range of members in a sorted set, by lexicographical range.
reactor.core.publisher.Flux<String>	zrangebylex(String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebylex(Object, Range).
reactor.core.publisher.Flux<String>	zrangebylex(String key, String min, String max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebylex(Object, Range).
reactor.core.publisher.Mono<Long>	zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, double min, double max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscore(ValueStreamingChannel, Object, Range).
reactor.core.publisher.Mono<Long>	zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, double min, double max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscore(ValueStreamingChannel, Object, Range, Limit limit).
reactor.core.publisher.Mono<Long>	zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, io.lettuce.core.Range<? extends Number> range)	Stream over a range of members in a sorted set, by score.
reactor.core.publisher.Mono<Long>	zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)	Stream over a range of members in a sorted set, by score.
reactor.core.publisher.Mono<Long>	zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscore(ValueStreamingChannel, Object, Range).
reactor.core.publisher.Mono<Long>	zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, String min, String max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscore(ValueStreamingChannel, Object, Range, Limit limit).
reactor.core.publisher.Flux<String>	zrangebyscore(String key, double min, double max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscore(Object, Range).
reactor.core.publisher.Flux<String>	zrangebyscore(String key, double min, double max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscore(Object, Range, Limit).
reactor.core.publisher.Flux<String>	zrangebyscore(String key, io.lettuce.core.Range<? extends Number> range)	Return a range of members in a sorted set, by score.
reactor.core.publisher.Flux<String>	zrangebyscore(String key, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)	Return a range of members in a sorted set, by score.
reactor.core.publisher.Flux<String>	zrangebyscore(String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscore(Object, Range).
reactor.core.publisher.Flux<String>	zrangebyscore(String key, String min, String max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscore(Object, Range, Limit).
reactor.core.publisher.Mono<Long>	zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, double min, double max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range).
reactor.core.publisher.Mono<Long>	zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, double min, double max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range, Limit limit).
reactor.core.publisher.Mono<Long>	zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, io.lettuce.core.Range<? extends Number> range)	Stream over a range of members with scores in a sorted set, by score.
reactor.core.publisher.Mono<Long>	zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)	Stream over a range of members with scores in a sorted set, by score.
reactor.core.publisher.Mono<Long>	zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range).
reactor.core.publisher.Mono<Long>	zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, String min, String max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range, Limit limit).
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrangebyscoreWithScores(String key, double min, double max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(Object, Range).
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrangebyscoreWithScores(String key, double min, double max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(Object, Range, Limit limit).
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrangebyscoreWithScores(String key, io.lettuce.core.Range<? extends Number> range)	Return a range of members with score in a sorted set, by score.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrangebyscoreWithScores(String key, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)	Return a range of members with score in a sorted set, by score.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrangebyscoreWithScores(String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(Object, Range).
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrangebyscoreWithScores(String key, String min, String max, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(Object, Range, Limit).
reactor.core.publisher.Mono<Long>	zrangestore(String s, String k1, io.lettuce.core.Range<Long> range)
reactor.core.publisher.Mono<Long>	zrangestorebylex(String s, String k1, io.lettuce.core.Range<? extends String> range, io.lettuce.core.Limit limit)
reactor.core.publisher.Mono<Long>	zrangestorebyscore(String s, String k1, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)
reactor.core.publisher.Mono<Long>	zrangeWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, long start, long stop)	已过时。
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrangeWithScores(String key, long start, long stop)	Return a range of members with scores in a sorted set, by index.
reactor.core.publisher.Mono<Long>	zrank(String key, String member)	Determine the index of a member in a sorted set.
reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<Long>>	zrankWithScore(String s, String s2)
reactor.core.publisher.Mono<Long>	zrem(String key, String... members)	Remove one or more members from a sorted set.
reactor.core.publisher.Mono<Long>	zremrangebylex(String key, io.lettuce.core.Range<? extends String> range)	Remove all members in a sorted set between the given lexicographical range.
reactor.core.publisher.Mono<Long>	zremrangebylex(String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zremrangebylex(Object, Range).
reactor.core.publisher.Mono<Long>	zremrangebyrank(String key, long start, long stop)	Remove all members in a sorted set within the given indexes.
reactor.core.publisher.Mono<Long>	zremrangebyscore(String key, double min, double max)	已过时。 Use RedisSortedSetReactiveCommands.zremrangebyscore(Object, Range).
reactor.core.publisher.Mono<Long>	zremrangebyscore(String key, io.lettuce.core.Range<? extends Number> range)	Remove all members in a sorted set within the given scores.
reactor.core.publisher.Mono<Long>	zremrangebyscore(String key, String min, String max)	已过时。 Use RedisSortedSetReactiveCommands.zremrangebyscore(Object, Range).
reactor.core.publisher.Mono<Long>	zrevrange(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, long start, long stop)	Stream over a range of members in a sorted set, by index, with scores ordered from high to low.
reactor.core.publisher.Flux<String>	zrevrange(String key, long start, long stop)	Return a range of members in a sorted set, by index, with scores ordered from high to low.
reactor.core.publisher.Flux<String>	zrevrangebylex(String key, io.lettuce.core.Range<? extends String> range)	Return a range of members in a sorted set, by lexicographical range ordered from high to low.
reactor.core.publisher.Flux<String>	zrevrangebylex(String key, io.lettuce.core.Range<? extends String> range, io.lettuce.core.Limit limit)	Return a range of members in a sorted set, by lexicographical range ordered from high to low.
reactor.core.publisher.Mono<Long>	zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, double max, double min)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range).
reactor.core.publisher.Mono<Long>	zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, double max, double min, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range, Limit).
reactor.core.publisher.Mono<Long>	zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, io.lettuce.core.Range<? extends Number> range)	Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
reactor.core.publisher.Mono<Long>	zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)	Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
reactor.core.publisher.Mono<Long>	zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, String max, String min)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range).
reactor.core.publisher.Mono<Long>	zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel, String key, String max, String min, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range, Limit).
reactor.core.publisher.Flux<String>	zrevrangebyscore(String key, double max, double min)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range).
reactor.core.publisher.Flux<String>	zrevrangebyscore(String key, double max, double min, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range, Limit).
reactor.core.publisher.Flux<String>	zrevrangebyscore(String key, io.lettuce.core.Range<? extends Number> range)	Return a range of members in a sorted set, by score, with scores ordered from high to low.
reactor.core.publisher.Flux<String>	zrevrangebyscore(String key, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)	Return a range of members in a sorted set, by score, with scores ordered from high to low.
reactor.core.publisher.Flux<String>	zrevrangebyscore(String key, String max, String min)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range).
reactor.core.publisher.Flux<String>	zrevrangebyscore(String key, String max, String min, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range, Limit).
reactor.core.publisher.Mono<Long>	zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, double max, double min)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range).
reactor.core.publisher.Mono<Long>	zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, double max, double min, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range, Limit).
reactor.core.publisher.Mono<Long>	zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, io.lettuce.core.Range<? extends Number> range)	Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
reactor.core.publisher.Mono<Long>	zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)	Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
reactor.core.publisher.Mono<Long>	zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, String max, String min)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range).
reactor.core.publisher.Mono<Long>	zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, String max, String min, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range, Limit).
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrevrangebyscoreWithScores(String key, double max, double min)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range).
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrevrangebyscoreWithScores(String key, double max, double min, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range, Limit).
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrevrangebyscoreWithScores(String key, io.lettuce.core.Range<? extends Number> range)	Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrevrangebyscoreWithScores(String key, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)	Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrevrangebyscoreWithScores(String key, String max, String min)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range).
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrevrangebyscoreWithScores(String key, String max, String min, long offset, long count)	已过时。 Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range, Limit).
reactor.core.publisher.Mono<Long>	zrevrangestore(String s, String k1, io.lettuce.core.Range<Long> range)
reactor.core.publisher.Mono<Long>	zrevrangestorebylex(String s, String k1, io.lettuce.core.Range<? extends String> range, io.lettuce.core.Limit limit)
reactor.core.publisher.Mono<Long>	zrevrangestorebyscore(String s, String k1, io.lettuce.core.Range<? extends Number> range, io.lettuce.core.Limit limit)
reactor.core.publisher.Mono<Long>	zrevrangeWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, long start, long stop)	Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zrevrangeWithScores(String key, long start, long stop)	Return a range of members with scores in a sorted set, by index, with scores ordered from high to low.
reactor.core.publisher.Mono<Long>	zrevrank(String key, String member)	Determine the index of a member in a sorted set, with scores ordered from high to low.
reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<Long>>	zrevrankWithScore(String s, String s2)
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	zscan(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key)	Incrementally iterate sorted sets elements and associated scores.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	zscan(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate sorted sets elements and associated scores.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	zscan(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, io.lettuce.core.ScanCursor scanCursor)	Incrementally iterate sorted sets elements and associated scores.
reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor>	zscan(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel, String key, io.lettuce.core.ScanCursor scanCursor, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate sorted sets elements and associated scores.
reactor.core.publisher.Mono<io.lettuce.core.ScoredValueScanCursor<String>>	zscan(String key)	Incrementally iterate sorted sets elements and associated scores.
reactor.core.publisher.Mono<io.lettuce.core.ScoredValueScanCursor<String>>	zscan(String key, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate sorted sets elements and associated scores.
reactor.core.publisher.Mono<io.lettuce.core.ScoredValueScanCursor<String>>	zscan(String key, io.lettuce.core.ScanCursor scanCursor)	Incrementally iterate sorted sets elements and associated scores.
reactor.core.publisher.Mono<io.lettuce.core.ScoredValueScanCursor<String>>	zscan(String key, io.lettuce.core.ScanCursor scanCursor, io.lettuce.core.ScanArgs scanArgs)	Incrementally iterate sorted sets elements and associated scores.
reactor.core.publisher.Mono<Double>	zscore(String key, String member)	Get the score associated with the given member in a sorted set.
reactor.core.publisher.Flux<String>	zunion(io.lettuce.core.ZAggregateArgs zAggregateArgs, String... strings)
reactor.core.publisher.Flux<String>	zunion(String... strings)
reactor.core.publisher.Mono<Long>	zunionstore(String destination, io.lettuce.core.ZStoreArgs storeArgs, String... keys)	Add multiple sorted sets and store the resulting sorted set in a new key.
reactor.core.publisher.Mono<Long>	zunionstore(String destination, String... keys)	Add multiple sorted sets and store the resulting sorted set in a new key.
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zunionWithScores(io.lettuce.core.ZAggregateArgs zAggregateArgs, String... strings)
reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>>	zunionWithScores(String... strings)

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ClusterReactiveCommands

public ClusterReactiveCommands()

方法详细资料

getConnection

public io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String> getConnection(String nodeId)

Retrieve a connection to the specified cluster node using the nodeId. Host and port are looked up in the node list. In contrast to the RedisAdvancedClusterReactiveCommands, node-connections do not route commands to other cluster nodes

指定者:

getConnection 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

参数:

nodeId - the node Id.

返回:

a connection to the requested cluster node.

getConnection

public io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String> getConnection(String host,
 int port)

Retrieve a connection to the specified cluster node using host and port. In contrast to the RedisAdvancedClusterReactiveCommands, node-connections do not route commands to other cluster nodes. Host and port connections are verified by default for cluster membership, see ClusterClientOptions#isValidateClusterNodeMembership().

指定者:

getConnection 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

参数:

host - the host.

port - the port.

返回:

a connection to the requested cluster node.

getStatefulConnection

@Deprecated
public io.lettuce.core.cluster.api.StatefulRedisClusterConnection<String,String> getStatefulConnection()

已过时。

指定者:

getStatefulConnection 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

返回:

the underlying connection.

setTimeout

@Deprecated
public void setTimeout(Duration timeout)

已过时。

Set the default timeout for operations. A zero timeout value indicates to not time out.

指定者:

setTimeout 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

timeout - the timeout value.

clusterBumpepoch

public reactor.core.publisher.Mono<String> clusterBumpepoch()

Generate a new config epoch, incrementing the current epoch, assign the new epoch to this node, WITHOUT any consensus and persist the configuration on disk before sending packets with the new configuration.

指定者:

clusterBumpepoch 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String simple-string-reply If the new config epoch is generated and assigned either BUMPED (epoch) or STILL (epoch) are returned.

clusterMeet

public reactor.core.publisher.Mono<String> clusterMeet(String ip,
 int port)

Meet another cluster node to include the node into the cluster. The command starts the cluster handshake and returns with OK when the node was added to the cluster.

指定者:

clusterMeet 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

ip - IP address of the host.

port - port number.

返回:

String simple-string-reply.

clusterForget

public reactor.core.publisher.Mono<String> clusterForget(String nodeId)

Blacklist and remove the cluster node from the cluster.

指定者:

clusterForget 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

nodeId - the node Id.

返回:

String simple-string-reply.

clusterAddSlots

public reactor.core.publisher.Mono<String> clusterAddSlots(int... slots)

Adds slots to the cluster node. The current node will become the master for the specified slots.

指定者:

clusterAddSlots 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

slots - one or more slots from 0 to 16384.

返回:

String simple-string-reply.

clusterDelSlots

public reactor.core.publisher.Mono<String> clusterDelSlots(int... slots)

Removes slots from the cluster node.

指定者:

clusterDelSlots 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

slots - one or more slots from 0 to 16384.

返回:

String simple-string-reply.

clusterDelSlotsRange

public reactor.core.publisher.Mono<String> clusterDelSlotsRange(io.lettuce.core.Range<Integer>... ranges)

指定者:

clusterDelSlotsRange 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

clusterSetSlotNode

public reactor.core.publisher.Mono<String> clusterSetSlotNode(int slot,
 String nodeId)

Assign a slot to a node. The command migrates the specified slot from the current node to the specified node in nodeId

指定者:

clusterSetSlotNode 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

slot - the slot.

nodeId - the id of the node that will become the master for the slot.

返回:

String simple-string-reply.

clusterSetSlotStable

public reactor.core.publisher.Mono<String> clusterSetSlotStable(int slot)

Clears migrating / importing state from the slot.

指定者:

clusterSetSlotStable 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

slot - the slot.

返回:

String simple-string-reply.

clusterShards

public reactor.core.publisher.Mono<List<Object>> clusterShards()

指定者:

clusterShards 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

clusterSetSlotMigrating

public reactor.core.publisher.Mono<String> clusterSetSlotMigrating(int slot,
 String nodeId)

Flag a slot as MIGRATING (outgoing) towards the node specified in nodeId. The slot must be handled by the current node in order to be migrated.

指定者:

clusterSetSlotMigrating 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

slot - the slot.

nodeId - the id of the node is targeted to become the master for the slot.

返回:

String simple-string-reply.

clusterSetSlotImporting

public reactor.core.publisher.Mono<String> clusterSetSlotImporting(int slot,
 String nodeId)

Flag a slot as IMPORTING (incoming) from the node specified in nodeId.

指定者:

clusterSetSlotImporting 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

slot - the slot.

nodeId - the id of the node is the master of the slot.

返回:

String simple-string-reply.

clusterInfo

public reactor.core.publisher.Mono<String> clusterInfo()

Get information and statistics about the cluster viewed by the current node.

指定者:

clusterInfo 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String bulk-string-reply as a collection of text lines.

clusterMyId

public reactor.core.publisher.Mono<String> clusterMyId()

Obtain the nodeId for the currently connected node.

指定者:

clusterMyId 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String simple-string-reply.

clusterNodes

public reactor.core.publisher.Mono<String> clusterNodes()

Obtain details about all cluster nodes. Can be parsed using ClusterPartitionParser.parse(java.util.List<java.lang.Object>)

指定者:

clusterNodes 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String bulk-string-reply as a collection of text lines.

clusterSlaves

@Deprecated
public reactor.core.publisher.Flux<String> clusterSlaves(String nodeId)

已过时。

List replicas for a certain node identified by its nodeId. Can be parsed using ClusterPartitionParser.parse(java.util.List<java.lang.Object>)

指定者:

clusterSlaves 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

nodeId - node id of the master node.

返回:

List<String> array-reply list of replicas. The command returns data in the same format as clusterNodes() but one line per replica.

clusterGetKeysInSlot

public reactor.core.publisher.Flux<String> clusterGetKeysInSlot(int slot,
 int count)

Retrieve the list of keys within the slot.

指定者:

clusterGetKeysInSlot 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

slot - the slot.

count - maximal number of keys.

返回:

List<K> array-reply list of keys.

clusterCountKeysInSlot

public reactor.core.publisher.Mono<Long> clusterCountKeysInSlot(int slot)

Returns the number of keys in the specified Redis Cluster hash slot.

指定者:

clusterCountKeysInSlot 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

slot - the slot.

返回:

Integer reply: The number of keys in the specified hash slot, or an error if the hash slot is invalid.

clusterAddSlotsRange

public reactor.core.publisher.Mono<String> clusterAddSlotsRange(io.lettuce.core.Range<Integer>... ranges)

指定者:

clusterAddSlotsRange 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

clusterCountFailureReports

public reactor.core.publisher.Mono<Long> clusterCountFailureReports(String nodeId)

Returns the number of failure reports for the specified node. Failure reports are the way Redis Cluster uses in order to promote a PFAIL state, that means a node is not reachable, to a FAIL state, that means that the majority of masters in the cluster agreed within a window of time that the node is not reachable.

指定者:

clusterCountFailureReports 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

nodeId - the node id.

返回:

Integer reply: The number of active failure reports for the node.

clusterKeyslot

public reactor.core.publisher.Mono<Long> clusterKeyslot(String key)

Returns an integer identifying the hash slot the specified key hashes to. This command is mainly useful for debugging and testing, since it exposes via an API the underlying Redis implementation of the hashing algorithm. Basically the same as SlotHash.getSlot(byte[]). If not, call Houston and report that we've got a problem.

指定者:

clusterKeyslot 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

key - the key.

返回:

Integer reply: The hash slot number.

clusterSaveconfig

public reactor.core.publisher.Mono<String> clusterSaveconfig()

Forces a node to save the nodes.conf configuration on disk.

指定者:

clusterSaveconfig 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String simple-string-reply: OK or an error if the operation fails.

clusterSetConfigEpoch

public reactor.core.publisher.Mono<String> clusterSetConfigEpoch(long configEpoch)

This command sets a specific config epoch in a fresh node. It only works when:

• The nodes table of the node is empty.
• The node current config epoch is zero.

指定者:

clusterSetConfigEpoch 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

configEpoch - the config epoch.

返回:

String simple-string-reply: OK or an error if the operation fails.

clusterSlots

public reactor.core.publisher.Flux<Object> clusterSlots()

Get array of cluster slots to node mappings.

指定者:

clusterSlots 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

List<Object> array-reply nested list of slot ranges with IP/Port mappings.

asking

public reactor.core.publisher.Mono<String> asking()

The asking command is required after a -ASK redirection. The client should issue ASKING before to actually send the command to the target instance. See the Redis Cluster specification for more information.

指定者:

asking 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String simple-string-reply.

auth

public reactor.core.publisher.Mono<String> auth(CharSequence charSequence)

指定者:

auth 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

auth

public reactor.core.publisher.Mono<String> auth(String s,
 CharSequence charSequence)

指定者:

auth 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

clusterReplicate

public reactor.core.publisher.Mono<String> clusterReplicate(String nodeId)

Turn this node into a replica of the node with the id nodeId.

指定者:

clusterReplicate 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

nodeId - master node id.

返回:

String simple-string-reply.

clusterReplicas

public reactor.core.publisher.Flux<String> clusterReplicas(String s)

指定者:

clusterReplicas 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

clusterFailover

public reactor.core.publisher.Mono<String> clusterFailover(boolean force)

Failover a cluster node. Turns the currently connected node into a master and the master into its replica.

指定者:

clusterFailover 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

force - do not coordinate with master if true.

返回:

String simple-string-reply.

clusterFailover

public reactor.core.publisher.Mono<String> clusterFailover(boolean b,
 boolean b1)

指定者:

clusterFailover 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

clusterReset

public reactor.core.publisher.Mono<String> clusterReset(boolean hard)

Reset a node performing a soft or hard reset:

• All other nodes are forgotten
• All the assigned / open slots are released
• If the node is a replica, it turns into a master
• Only for hard reset: a new Node ID is generated
• Only for hard reset: currentEpoch and configEpoch are set to 0
• The new configuration is saved and the cluster state updated
• If the node was a replica, the whole data set is flushed away

指定者:

clusterReset 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

参数:

hard - true for hard reset. Generates a new nodeId and currentEpoch/configEpoch are set to 0.

返回:

String simple-string-reply.

clusterFlushslots

public reactor.core.publisher.Mono<String> clusterFlushslots()

Delete all the slots associated with the specified node. The number of deleted slots is returned.

指定者:

clusterFlushslots 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String simple-string-reply.

publish

public reactor.core.publisher.Mono<Long> publish(String channel,
 String message)

Post a message to a channel.

指定者:

publish 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

参数:

channel - the channel type: key.

message - the message type: value.

返回:

Long integer-reply the number of clients that received the message.

pubsubChannels

public reactor.core.publisher.Flux<String> pubsubChannels()

Lists the currently *active channels*.

指定者:

pubsubChannels 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

返回:

K array-reply a list of active channels, optionally matching the specified pattern.

pubsubChannels

public reactor.core.publisher.Flux<String> pubsubChannels(String channel)

Lists the currently *active channels*.

指定者:

pubsubChannels 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

参数:

channel - the key.

返回:

K array-reply a list of active channels, optionally matching the specified pattern.

pubsubNumsub

public reactor.core.publisher.Mono<Map<String,Long>> pubsubNumsub(String... channels)

Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.

指定者:

pubsubNumsub 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

参数:

channels - channel keys.

返回:

array-reply a list of channels and number of subscribers for every channel.

pubsubNumpat

public reactor.core.publisher.Mono<Long> pubsubNumpat()

Returns the number of subscriptions to patterns.

指定者:

pubsubNumpat 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

返回:

Long integer-reply the number of patterns all the clients are subscribed to.

echo

public reactor.core.publisher.Mono<String> echo(String msg)

Echo the given string.

指定者:

echo 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

参数:

msg - the message type: value.

返回:

V bulk-string-reply.

role

public reactor.core.publisher.Flux<Object> role()

Return the role of the instance in the context of replication.

指定者:

role 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

返回:

Object array-reply where the first element is one of master, slave, sentinel and the additional elements are role-specific.

ping

public reactor.core.publisher.Mono<String> ping()

Ping the server.

指定者:

ping 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

返回:

String simple-string-reply.

readOnly

public reactor.core.publisher.Mono<String> readOnly()

Tells a Redis cluster replica node that the client is ok reading possibly stale data and is not interested in running write queries.

指定者:

readOnly 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

指定者:

readOnly 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String simple-string-reply.

readWrite

public reactor.core.publisher.Mono<String> readWrite()

Resets readOnly flag.

指定者:

readWrite 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

指定者:

readWrite 在接口中 io.lettuce.core.cluster.api.reactive.RedisClusterReactiveCommands<String,String>

返回:

String simple-string-reply.

quit

public reactor.core.publisher.Mono<String> quit()

Instructs Redis to disconnect the connection. Note that if auto-reconnect is enabled then Lettuce will auto-reconnect if the connection was disconnected. Use StatefulConnection.close() to close connections and release resources.

指定者:

quit 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

返回:

String simple-string-reply always OK.

waitForReplication

public reactor.core.publisher.Mono<Long> waitForReplication(int replicas,
 long timeout)

Wait for replication.

指定者:

waitForReplication 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

参数:

replicas - minimum number of replicas.

timeout - timeout in milliseconds.

返回:

number of replicas.

dispatch

public <T> reactor.core.publisher.Flux<T> dispatch(io.lettuce.core.protocol.ProtocolKeyword type,
 io.lettuce.core.output.CommandOutput<String,String,?> output)

Dispatch a command to the Redis Server. Please note the command output type must fit to the command response.

指定者:

dispatch 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

参数:

type - the command, must not be null.

output - the command output, must not be null.

返回:

the command response.

dispatch

public <T> reactor.core.publisher.Flux<T> dispatch(io.lettuce.core.protocol.ProtocolKeyword type,
 io.lettuce.core.output.CommandOutput<String,String,?> output,
 io.lettuce.core.protocol.CommandArgs<String,String> args)

Dispatch a command to the Redis Server. Please note the command output type must fit to the command response.

指定者:

dispatch 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

参数:

type - the command, must not be null.

output - the command output, must not be null.

args - the command arguments, must not be null.

返回:

the command response.

isOpen

@Deprecated
public boolean isOpen()

已过时。

指定者:

isOpen 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

返回:

true if the connection is open (connected and not closed).

reset

@Deprecated
public void reset()

已过时。

Reset the command state. Queued commands will be canceled and the internal state will be reset. This is useful when the internal state machine gets out of sync with the connection.

指定者:

reset 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

setAutoFlushCommands

@Deprecated
public void setAutoFlushCommands(boolean autoFlush)

已过时。

Disable or enable auto-flush behavior. Default is true. If autoFlushCommands is disabled, multiple commands can be issued without writing them actually to the transport. Commands are buffered until a flushCommands() is issued. After calling flushCommands() commands are sent to the transport and executed by Redis.

指定者:

setAutoFlushCommands 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

参数:

autoFlush - state of autoFlush.

flushCommands

@Deprecated
public void flushCommands()

已过时。

Flush pending commands. This commands forces a flush on the channel and can be used to buffer ("pipeline") commands to achieve batching. No-op if channel is not connected.

指定者:

flushCommands 在接口中 io.lettuce.core.api.reactive.BaseRedisReactiveCommands<String,String>

copy

public reactor.core.publisher.Mono<Boolean> copy(String s,
 String k1)

指定者:

copy 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

copy

public reactor.core.publisher.Mono<Boolean> copy(String s,
 String k1,
 io.lettuce.core.CopyArgs copyArgs)

指定者:

copy 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

del

public reactor.core.publisher.Mono<Long> del(String... keys)

Delete one or more keys with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

指定者:

del 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

del 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

keys - the keys.

返回:

Long integer-reply The number of keys that were removed.

unlink

public reactor.core.publisher.Mono<Long> unlink(String... keys)

Unlink one or more keys with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

指定者:

unlink 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

unlink 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

keys - the keys.

返回:

Long integer-reply The number of keys that were removed.

dump

public reactor.core.publisher.Mono<byte[]> dump(String key)

Return a serialized version of the value stored at the specified key.

指定者:

dump 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

byte[] bulk-string-reply the serialized value.

exists

public reactor.core.publisher.Mono<Long> exists(String... keys)

Determine how many keys exist with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

指定者:

exists 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

exists 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

keys - the keys.

返回:

Long integer-reply specifically: Number of existing keys.

expire

public reactor.core.publisher.Mono<Boolean> expire(String key,
 long seconds)

Set a key's time to live in seconds.

指定者:

expire 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

seconds - the seconds type: long.

返回:

Boolean integer-reply specifically:

true if the timeout was set. false if key does not exist or the timeout could not be set.

expire

public reactor.core.publisher.Mono<Boolean> expire(String s,
 long l,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

expire 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

expire

public reactor.core.publisher.Mono<Boolean> expire(String s,
 Duration duration)

指定者:

expire 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

expire

public reactor.core.publisher.Mono<Boolean> expire(String s,
 Duration duration,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

expire 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

expireat

public reactor.core.publisher.Mono<Boolean> expireat(String key,
 Date timestamp)

Set the expiration for a key as a UNIX timestamp.

指定者:

expireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

timestamp - the timestamp type: posix time.

返回:

Boolean integer-reply specifically:

true if the timeout was set. false if key does not exist or the timeout could not be set (see: EXPIRE).

expireat

public reactor.core.publisher.Mono<Boolean> expireat(String s,
 Date date,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

expireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

expireat

public reactor.core.publisher.Mono<Boolean> expireat(String s,
 Instant instant)

指定者:

expireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

expireat

public reactor.core.publisher.Mono<Boolean> expireat(String s,
 Instant instant,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

expireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

expiretime

public reactor.core.publisher.Mono<Long> expiretime(String s)

指定者:

expiretime 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

expireat

public reactor.core.publisher.Mono<Boolean> expireat(String key,
 long timestamp)

Set the expiration for a key as a UNIX timestamp.

指定者:

expireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

timestamp - the timestamp type: posix time.

返回:

Boolean integer-reply specifically:

true if the timeout was set. false if key does not exist or the timeout could not be set (see: EXPIRE).

expireat

public reactor.core.publisher.Mono<Boolean> expireat(String s,
 long l,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

expireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

append

public reactor.core.publisher.Mono<Long> append(String key,
 String value)

Append a value to a key.

指定者:

append 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

value - the value.

返回:

Long integer-reply the length of the string after the append operation.

bitcount

public reactor.core.publisher.Mono<Long> bitcount(String key)

Count set bits in a string.

指定者:

bitcount 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply The number of bits set to 1.

bitcount

public reactor.core.publisher.Mono<Long> bitcount(String key,
 long start,
 long end)

Count set bits in a string.

指定者:

bitcount 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

start - the start.

end - the end.

返回:

Long integer-reply The number of bits set to 1.

bitfield

public reactor.core.publisher.Flux<io.lettuce.core.Value<Long>> bitfield(String key,
 io.lettuce.core.BitFieldArgs bitFieldArgs)

Execute BITFIELD with its subcommands.

指定者:

bitfield 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

bitFieldArgs - the args containing subcommands, must not be null.

返回:

Long bulk-reply the results from the bitfield commands.

bitpos

public reactor.core.publisher.Mono<Long> bitpos(String key,
 boolean state)

Find first bit set or clear in a string.

指定者:

bitpos 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

state - the state.

返回:

Long integer-reply The command returns the position of the first bit set to 1 or 0 according to the request.

If we look for set bits (the bit argument is 1) and the string is empty or composed of just zero bytes, -1 is returned.

If we look for clear bits (the bit argument is 0) and the string only contains bit set to 1, the function returns the first bit not part of the string on the right. So if the string is tree bytes set to the value 0xff the command BITPOS key 0 will return 24, since up to bit 23 all the bits are 1.

Basically the function consider the right of the string as padded with zeros if you look for clear bits and specify no range or the start argument only.

bitpos

public reactor.core.publisher.Mono<Long> bitpos(String key,
 boolean state,
 long start)

Find first bit set or clear in a string.

指定者:

bitpos 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

state - the bit type: long.

start - the start type: long.

返回:

Long integer-reply The command returns the position of the first bit set to 1 or 0 according to the request.

If we look for set bits (the bit argument is 1) and the string is empty or composed of just zero bytes, -1 is returned.

If we look for clear bits (the bit argument is 0) and the string only contains bit set to 1, the function returns the first bit not part of the string on the right. So if the string is tree bytes set to the value 0xff the command BITPOS key 0 will return 24, since up to bit 23 all the bits are 1.

Basically the function consider the right of the string as padded with zeros if you look for clear bits and specify no range or the start argument only.

bitpos

public reactor.core.publisher.Mono<Long> bitpos(String key,
 boolean state,
 long start,
 long end)

Find first bit set or clear in a string.

指定者:

bitpos 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

state - the bit type: long.

start - the start type: long.

end - the end type: long.

返回:

Long integer-reply The command returns the position of the first bit set to 1 or 0 according to the request.

If we look for set bits (the bit argument is 1) and the string is empty or composed of just zero bytes, -1 is returned.

If we look for clear bits (the bit argument is 0) and the string only contains bit set to 1, the function returns the first bit not part of the string on the right. So if the string is tree bytes set to the value 0xff the command BITPOS key 0 will return 24, since up to bit 23 all the bits are 1.

Basically the function consider the right of the string as padded with zeros if you look for clear bits and specify no range or the start argument only.

However this behavior changes if you are looking for clear bits and specify a range with both start and end. If no clear bit is found in the specified range, the function returns -1 as the user specified a clear range and there are no 0 bits in that range.

bitopAnd

public reactor.core.publisher.Mono<Long> bitopAnd(String destination,
 String... keys)

Perform bitwise AND between strings.

指定者:

bitopAnd 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

destination - result key of the operation.

keys - operation input key names.

返回:

Long integer-reply The size of the string stored in the destination key, that is equal to the size of the longest input string.

bitopNot

public reactor.core.publisher.Mono<Long> bitopNot(String destination,
 String source)

Perform bitwise NOT between strings.

指定者:

bitopNot 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

destination - result key of the operation.

source - operation input key names.

返回:

Long integer-reply The size of the string stored in the destination key, that is equal to the size of the longest input string.

bitopOr

public reactor.core.publisher.Mono<Long> bitopOr(String destination,
 String... keys)

Perform bitwise OR between strings.

指定者:

bitopOr 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

destination - result key of the operation.

keys - operation input key names.

返回:

Long integer-reply The size of the string stored in the destination key, that is equal to the size of the longest input string.

bitopXor

public reactor.core.publisher.Mono<Long> bitopXor(String destination,
 String... keys)

Perform bitwise XOR between strings.

指定者:

bitopXor 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

destination - result key of the operation.

keys - operation input key names.

返回:

Long integer-reply The size of the string stored in the destination key, that is equal to the size of the longest input string.

decr

public reactor.core.publisher.Mono<Long> decr(String key)

Decrement the integer value of a key by one.

指定者:

decr 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply the value of key after the decrement.

decrby

public reactor.core.publisher.Mono<Long> decrby(String key,
 long amount)

Decrement the integer value of a key by the given number.

指定者:

decrby 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

amount - the decrement type: long.

返回:

Long integer-reply the value of key after the decrement.

get

public reactor.core.publisher.Mono<String> get(String key)

Get the value of a key.

指定者:

get 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

返回:

V bulk-string-reply the value of key, or null when key does not exist.

getbit

public reactor.core.publisher.Mono<Long> getbit(String key,
 long offset)

Returns the bit value at offset in the string value stored at key.

指定者:

getbit 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

offset - the offset type: long.

返回:

Long integer-reply the bit value stored at offset.

getdel

public reactor.core.publisher.Mono<String> getdel(String s)

指定者:

getdel 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

getex

public reactor.core.publisher.Mono<String> getex(String s,
 io.lettuce.core.GetExArgs getExArgs)

指定者:

getex 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

getrange

public reactor.core.publisher.Mono<String> getrange(String key,
 long start,
 long end)

Get a substring of the string stored at a key.

指定者:

getrange 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

start - the start type: long.

end - the end type: long.

返回:

V bulk-string-reply.

getset

public reactor.core.publisher.Mono<String> getset(String key,
 String value)

Set the string value of a key and return its old value.

指定者:

getset 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

value - the value.

返回:

V bulk-string-reply the old value stored at key, or null when key did not exist.

incr

public reactor.core.publisher.Mono<Long> incr(String key)

Increment the integer value of a key by one.

指定者:

incr 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply the value of key after the increment.

incrby

public reactor.core.publisher.Mono<Long> incrby(String key,
 long amount)

Increment the integer value of a key by the given amount.

指定者:

incrby 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

amount - the increment type: long.

返回:

Long integer-reply the value of key after the increment.

incrbyfloat

public reactor.core.publisher.Mono<Double> incrbyfloat(String key,
 double amount)

Increment the float value of a key by the given amount.

指定者:

incrbyfloat 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

amount - the increment type: double.

返回:

Double bulk-string-reply the value of key after the increment.

mget

public reactor.core.publisher.Flux<io.lettuce.core.KeyValue<String,String>> mget(String... keys)

Get the values of all the given keys with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

指定者:

mget 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

mget 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

keys - the key.

返回:

V array-reply list of values at the specified keys.

mget

@Deprecated
public reactor.core.publisher.Mono<Long> mget(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel,
 String... keys)

已过时。

Stream over the values of all the given keys.

指定者:

mget 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

channel - the channel.

keys - the keys.

返回:

Long array-reply list of values at the specified keys.

mset

public reactor.core.publisher.Mono<String> mset(Map<String,String> map)

Set multiple keys to multiple values with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

指定者:

mset 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

mset 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

map - the map.

返回:

String simple-string-reply always OK since MSET can't fail.

msetnx

public reactor.core.publisher.Mono<Boolean> msetnx(Map<String,String> map)

Set multiple keys to multiple values, only if none of the keys exist with pipelining. Cross-slot keys will result in multiple calls to the particular cluster nodes.

指定者:

msetnx 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

msetnx 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

map - the null.

返回:

Boolean integer-reply specifically:

1 if the all the keys were set. 0 if no key was set (at least one key already existed).

set

public reactor.core.publisher.Mono<String> set(String key,
 String value)

Set the string value of a key.

指定者:

set 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

value - the value.

返回:

String simple-string-reply OK if SET was executed correctly.

set

public reactor.core.publisher.Mono<String> set(String key,
 String value,
 io.lettuce.core.SetArgs setArgs)

Set the string value of a key.

指定者:

set 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

value - the value.

setArgs - the setArgs.

返回:

String simple-string-reply OK if SET was executed correctly.

setGet

public reactor.core.publisher.Mono<String> setGet(String s,
 String s2)

指定者:

setGet 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

setGet

public reactor.core.publisher.Mono<String> setGet(String s,
 String s2,
 io.lettuce.core.SetArgs setArgs)

指定者:

setGet 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

setbit

public reactor.core.publisher.Mono<Long> setbit(String key,
 long offset,
 int value)

Sets or clears the bit at offset in the string value stored at key.

指定者:

setbit 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

offset - the offset type: long.

value - the value type: string.

返回:

Long integer-reply the original bit value stored at offset.

setex

public reactor.core.publisher.Mono<String> setex(String key,
 long seconds,
 String value)

Set the value and expiration of a key.

指定者:

setex 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

seconds - the seconds type: long.

value - the value.

返回:

String simple-string-reply.

psetex

public reactor.core.publisher.Mono<String> psetex(String key,
 long milliseconds,
 String value)

Set the value and expiration in milliseconds of a key.

指定者:

psetex 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

milliseconds - the milliseconds type: long.

value - the value.

返回:

String simple-string-reply.

setnx

public reactor.core.publisher.Mono<Boolean> setnx(String key,
 String value)

Set the value of a key, only if the key does not exist.

指定者:

setnx 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

value - the value.

返回:

Boolean integer-reply specifically:

1 if the key was set 0 if the key was not set.

setrange

public reactor.core.publisher.Mono<Long> setrange(String key,
 long offset,
 String value)

Overwrite part of a string at key starting at the specified offset.

指定者:

setrange 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

offset - the offset type: long.

value - the value.

返回:

Long integer-reply the length of the string after it was modified by the command.

stralgoLcs

public reactor.core.publisher.Mono<io.lettuce.core.StringMatchResult> stralgoLcs(io.lettuce.core.StrAlgoArgs strAlgoArgs)

The STRALGO command implements complex algorithms that operate on strings. This method uses the LCS algorithm (longest common substring).

• Without modifiers the string representing the longest common substring is returned.
• When LEN is given the command returns the length of the longest common substring.
• When IDX is given the command returns an array with the LCS length and all the ranges in both the strings, start and end offset for each string, where there are matches. When WITHMATCHLEN is given each array representing a match will also have the length of the match.

指定者:

stralgoLcs 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

strAlgoArgs - command arguments.

返回:

StringMatchResult.

strlen

public reactor.core.publisher.Mono<Long> strlen(String key)

Get the length of the value stored in a key.

指定者:

strlen 在接口中 io.lettuce.core.api.reactive.RedisStringReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply the length of the string at key, or 0 when key does not exist.

bgrewriteaof

public reactor.core.publisher.Mono<String> bgrewriteaof()

Asynchronously rewrite the append-only file.

指定者:

bgrewriteaof 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply always OK.

bgsave

public reactor.core.publisher.Mono<String> bgsave()

Asynchronously save the dataset to disk.

指定者:

bgsave 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply.

clientCaching

public reactor.core.publisher.Mono<String> clientCaching(boolean b)

指定者:

clientCaching 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

clientGetname

public reactor.core.publisher.Mono<String> clientGetname()

Get the current connection name.

指定者:

clientGetname 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

K bulk-string-reply The connection name, or a null bulk reply if no name is set.

clientGetredir

public reactor.core.publisher.Mono<Long> clientGetredir()

指定者:

clientGetredir 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

clientSetname

public reactor.core.publisher.Mono<String> clientSetname(String name)

Set the current connection name on all cluster nodes with pipelining.

指定者:

clientSetname 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

clientSetname 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

name - the client name.

返回:

simple-string-reply OK if the connection name was successfully set.

clientSetinfo

public reactor.core.publisher.Mono<String> clientSetinfo(String s,
 String s1)

指定者:

clientSetinfo 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

clientTracking

public reactor.core.publisher.Mono<String> clientTracking(io.lettuce.core.TrackingArgs trackingArgs)

指定者:

clientTracking 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

clientKill

public reactor.core.publisher.Mono<String> clientKill(String addr)

Kill the connection of a client identified by ip:port.

指定者:

clientKill 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

addr - ip:port.

返回:

String simple-string-reply OK if the connection exists and has been closed.

clientKill

public reactor.core.publisher.Mono<Long> clientKill(io.lettuce.core.KillArgs killArgs)

Kill connections of clients which are filtered by killArgs.

指定者:

clientKill 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

killArgs - args for the kill operation.

返回:

Long integer-reply number of killed connections.

clientUnblock

public reactor.core.publisher.Mono<Long> clientUnblock(long id,
 io.lettuce.core.UnblockType type)

Unblock the specified blocked client.

指定者:

clientUnblock 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

id - the client id.

type - unblock type.

返回:

Long integer-reply number of unblocked connections.

从以下版本开始:

5.1

clientPause

public reactor.core.publisher.Mono<String> clientPause(long timeout)

Stop processing commands from clients for some time.

指定者:

clientPause 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

timeout - the timeout value in milliseconds.

返回:

String simple-string-reply The command returns OK or an error if the timeout is invalid.

clientList

public reactor.core.publisher.Mono<String> clientList()

Get the list of client connections.

指定者:

clientList 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String bulk-string-reply a unique string, formatted as follows: One client connection per line (separated by LF), each line is composed of a succession of property=value fields separated by a space character.

clientList

public reactor.core.publisher.Mono<String> clientList(io.lettuce.core.ClientListArgs clientListArgs)

指定者:

clientList 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

clientInfo

public reactor.core.publisher.Mono<String> clientInfo()

指定者:

clientInfo 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

clientNoEvict

public reactor.core.publisher.Mono<String> clientNoEvict(boolean b)

指定者:

clientNoEvict 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

clientId

public reactor.core.publisher.Mono<Long> clientId()

Get the id of the current connection.

指定者:

clientId 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

Long The command just returns the ID of the current connection.

从以下版本开始:

5.3

command

public reactor.core.publisher.Flux<Object> command()

Returns an array reply of details about all Redis commands.

指定者:

command 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

Object array-reply.

commandInfo

public reactor.core.publisher.Flux<Object> commandInfo(String... commands)

Returns an array reply of details about the requested commands.

指定者:

commandInfo 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

commands - the commands to query for.

返回:

Object array-reply.

commandInfo

public reactor.core.publisher.Flux<Object> commandInfo(io.lettuce.core.protocol.CommandType... commands)

Returns an array reply of details about the requested commands.

指定者:

commandInfo 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

commands - the commands to query for.

返回:

Object array-reply.

commandCount

public reactor.core.publisher.Mono<Long> commandCount()

Get total number of Redis commands.

指定者:

commandCount 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

Long integer-reply of number of total commands in this Redis server.

configGet

public reactor.core.publisher.Mono<Map<String,String>> configGet(String parameter)

Get the value of a configuration parameter.

指定者:

configGet 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

parameter - name of the parameter.

返回:

Map<String, String> bulk-string-reply.

configGet

public reactor.core.publisher.Mono<Map<String,String>> configGet(String... strings)

指定者:

configGet 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

configResetstat

public reactor.core.publisher.Mono<String> configResetstat()

Reset the stats returned by INFO.

指定者:

configResetstat 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply always OK.

configRewrite

public reactor.core.publisher.Mono<String> configRewrite()

Rewrite the configuration file with the in memory configuration.

指定者:

configRewrite 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply OK when the configuration was rewritten properly. Otherwise an error is returned.

configSet

public reactor.core.publisher.Mono<String> configSet(String parameter,
 String value)

Set a configuration parameter to the given value.

指定者:

configSet 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

parameter - the parameter name.

value - the parameter value.

返回:

String simple-string-reply: OK when the configuration was set properly. Otherwise an error is returned.

configSet

public reactor.core.publisher.Mono<String> configSet(Map<String,String> map)

指定者:

configSet 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

flushall

public reactor.core.publisher.Mono<String> flushall()

Remove all keys from all databases on all cluster masters with pipelining.

指定者:

flushall 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

flushall 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply.

flushall

public reactor.core.publisher.Mono<String> flushall(io.lettuce.core.FlushMode flushMode)

指定者:

flushall 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

flushallAsync

public reactor.core.publisher.Mono<String> flushallAsync()

Remove all keys asynchronously from all databases on all cluster upstream nodes with pipelining.

指定者:

flushallAsync 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

flushallAsync 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply

从以下版本开始:

5.3.3

flushdb

public reactor.core.publisher.Mono<String> flushdb()

Remove all keys from the current database on all cluster masters with pipelining.

指定者:

flushdb 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

flushdb 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply.

flushdb

public reactor.core.publisher.Mono<String> flushdb(io.lettuce.core.FlushMode flushMode)

指定者:

flushdb 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

flushdbAsync

@Deprecated
public reactor.core.publisher.Mono<String> flushdbAsync()

已过时。

Remove all keys asynchronously from the current database.

指定者:

flushdbAsync 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply.

info

public reactor.core.publisher.Mono<String> info()

Get information and statistics about the server.

指定者:

info 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String bulk-string-reply as a collection of text lines.

info

public reactor.core.publisher.Mono<String> info(String section)

Get information and statistics about the server.

指定者:

info 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

section - the section type: string.

返回:

String bulk-string-reply as a collection of text lines.

lastsave

public reactor.core.publisher.Mono<Date> lastsave()

Get the UNIX time stamp of the last successful save to disk.

指定者:

lastsave 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

Date integer-reply an UNIX time stamp.

memoryUsage

public reactor.core.publisher.Mono<Long> memoryUsage(String key)

Reports the number of bytes that a key and its value require to be stored in RAM.

指定者:

memoryUsage 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

key - the key.

返回:

memory usage in bytes.

从以下版本开始:

5.2

replicaof

public reactor.core.publisher.Mono<String> replicaof(String s,
 int i)

指定者:

replicaof 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

replicaofNoOne

public reactor.core.publisher.Mono<String> replicaofNoOne()

指定者:

replicaofNoOne 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

save

public reactor.core.publisher.Mono<String> save()

Synchronously save the dataset to disk.

指定者:

save 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply The commands returns OK on success.

dbsize

public reactor.core.publisher.Mono<Long> dbsize()

Return the number of keys in the selected database on all cluster masters.

指定者:

dbsize 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

dbsize 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

Long integer-reply.

debugCrashAndRecover

public reactor.core.publisher.Mono<String> debugCrashAndRecover(Long delay)

Crash and recover.

指定者:

debugCrashAndRecover 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

delay - optional delay in milliseconds.

返回:

String simple-string-reply.

debugHtstats

public reactor.core.publisher.Mono<String> debugHtstats(int db)

Get debugging information about the internal hash-table state.

指定者:

debugHtstats 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

db - the database number.

返回:

String simple-string-reply.

debugObject

public reactor.core.publisher.Mono<String> debugObject(String key)

Get debugging information about a key.

指定者:

debugObject 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

key - the key.

返回:

String simple-string-reply.

debugOom

public reactor.core.publisher.Mono<Void> debugOom()

Make the server crash: Out of memory.

指定者:

debugOom 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

nothing, because the server crashes before returning.

debugSegfault

public reactor.core.publisher.Mono<Void> debugSegfault()

Make the server crash: Invalid pointer access.

指定者:

debugSegfault 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

nothing, because the server crashes before returning.

debugReload

public reactor.core.publisher.Mono<String> debugReload()

Save RDB, clear the database and reload RDB.

指定者:

debugReload 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply The commands returns OK on success.

debugRestart

public reactor.core.publisher.Mono<String> debugRestart(Long delay)

Restart the server gracefully.

指定者:

debugRestart 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

delay - optional delay in milliseconds.

返回:

String simple-string-reply.

debugSdslen

public reactor.core.publisher.Mono<String> debugSdslen(String key)

Get debugging information about the internal SDS length.

指定者:

debugSdslen 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

key - the key.

返回:

String simple-string-reply.

keys

public reactor.core.publisher.Flux<String> keys(String pattern)

Find all keys matching the given pattern on all cluster masters.

指定者:

keys 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

keys 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

pattern - the pattern type: patternkey (pattern).

返回:

List<K> array-reply list of keys matching pattern.

keys

@Deprecated
public reactor.core.publisher.Mono<Long> keys(io.lettuce.core.output.KeyStreamingChannel<String> channel,
 String pattern)

已过时。

Find all keys matching the given pattern on all cluster masters.

指定者:

keys 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

keys 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

channel - the channel.

pattern - the pattern.

返回:

Long array-reply list of keys matching pattern.

migrate

public reactor.core.publisher.Mono<String> migrate(String host,
 int port,
 String key,
 int db,
 long timeout)

Atomically transfer a key from a Redis instance to another one.

指定者:

migrate 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

host - the host.

port - the port.

key - the key.

db - the database.

timeout - the timeout in milliseconds.

返回:

String simple-string-reply The command returns OK on success.

migrate

public reactor.core.publisher.Mono<String> migrate(String host,
 int port,
 int db,
 long timeout,
 io.lettuce.core.MigrateArgs<String> migrateArgs)

Atomically transfer one or more keys from a Redis instance to another one.

指定者:

migrate 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

host - the host.

port - the port.

db - the database.

timeout - the timeout in milliseconds.

migrateArgs - migrate args that allow to configure further options.

返回:

String simple-string-reply The command returns OK on success.

move

public reactor.core.publisher.Mono<Boolean> move(String key,
 int db)

Move a key to another database.

指定者:

move 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

db - the db type: long.

返回:

Boolean integer-reply specifically:.

objectEncoding

public reactor.core.publisher.Mono<String> objectEncoding(String key)

returns the kind of internal representation used in order to store the value associated with a key.

指定者:

objectEncoding 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

String.

objectFreq

public reactor.core.publisher.Mono<Long> objectFreq(String s)

指定者:

objectFreq 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

objectIdletime

public reactor.core.publisher.Mono<Long> objectIdletime(String key)

returns the number of seconds since the object stored at the specified key is idle (not requested by read or write operations).

指定者:

objectIdletime 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

number of seconds since the object stored at the specified key is idle.

objectRefcount

public reactor.core.publisher.Mono<Long> objectRefcount(String key)

returns the number of references of the value associated with the specified key.

指定者:

objectRefcount 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

Long.

persist

public reactor.core.publisher.Mono<Boolean> persist(String key)

Remove the expiration from a key.

指定者:

persist 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

Boolean integer-reply specifically:

true if the timeout was removed. false if key does not exist or does not have an associated timeout.

pexpire

public reactor.core.publisher.Mono<Boolean> pexpire(String key,
 long milliseconds)

Set a key's time to live in milliseconds.

指定者:

pexpire 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

milliseconds - the milliseconds type: long.

返回:

integer-reply, specifically:

true if the timeout was set. false if key does not exist or the timeout could not be set.

pexpire

public reactor.core.publisher.Mono<Boolean> pexpire(String s,
 long l,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

pexpire 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

pexpire

public reactor.core.publisher.Mono<Boolean> pexpire(String s,
 Duration duration)

指定者:

pexpire 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

pexpire

public reactor.core.publisher.Mono<Boolean> pexpire(String s,
 Duration duration,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

pexpire 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

pexpireat

public reactor.core.publisher.Mono<Boolean> pexpireat(String key,
 Date timestamp)

Set the expiration for a key as a UNIX timestamp specified in milliseconds.

指定者:

pexpireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

timestamp - the milliseconds-timestamp type: posix time.

返回:

Boolean integer-reply specifically:

true if the timeout was set. false if key does not exist or the timeout could not be set (see: EXPIRE).

pexpireat

public reactor.core.publisher.Mono<Boolean> pexpireat(String s,
 Date date,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

pexpireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

pexpireat

public reactor.core.publisher.Mono<Boolean> pexpireat(String s,
 Instant instant)

指定者:

pexpireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

pexpireat

public reactor.core.publisher.Mono<Boolean> pexpireat(String s,
 Instant instant,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

pexpireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

pexpiretime

public reactor.core.publisher.Mono<Long> pexpiretime(String s)

指定者:

pexpiretime 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

pexpireat

public reactor.core.publisher.Mono<Boolean> pexpireat(String key,
 long timestamp)

Set the expiration for a key as a UNIX timestamp specified in milliseconds.

指定者:

pexpireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

timestamp - the milliseconds-timestamp type: posix time.

返回:

Boolean integer-reply specifically:

true if the timeout was set. false if key does not exist or the timeout could not be set (see: EXPIRE).

pexpireat

public reactor.core.publisher.Mono<Boolean> pexpireat(String s,
 long l,
 io.lettuce.core.ExpireArgs expireArgs)

指定者:

pexpireat 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

pttl

public reactor.core.publisher.Mono<Long> pttl(String key)

Get the time to live for a key in milliseconds.

指定者:

pttl 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply TTL in milliseconds, or a negative value in order to signal an error (see the description above).

randomkey

public reactor.core.publisher.Mono<String> randomkey()

Return a random key from the keyspace on a random master.

指定者:

randomkey 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

randomkey 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

返回:

K bulk-string-reply the random key, or a Mono that completes empty when the database is empty.

rename

public reactor.core.publisher.Mono<String> rename(String key,
 String newKey)

Rename a key.

指定者:

rename 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

newKey - the newkey type: key.

返回:

String simple-string-reply.

renamenx

public reactor.core.publisher.Mono<Boolean> renamenx(String key,
 String newKey)

Rename a key, only if the new key does not exist.

指定者:

renamenx 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

newKey - the newkey type: key.

返回:

Boolean integer-reply specifically:

true if key was renamed to newkey. false if newkey already exists.

restore

public reactor.core.publisher.Mono<String> restore(String key,
 long ttl,
 byte[] value)

Create a key using the provided serialized value, previously obtained using DUMP.

指定者:

restore 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

ttl - the ttl type: long.

value - the serialized-value type: string.

返回:

String simple-string-reply The command returns OK on success.

restore

public reactor.core.publisher.Mono<String> restore(String key,
 byte[] value,
 io.lettuce.core.RestoreArgs args)

Create a key using the provided serialized value, previously obtained using DUMP.

指定者:

restore 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

value - the serialized-value type: string.

args - the RestoreArgs, must not be null.

返回:

String simple-string-reply The command returns OK on success.

从以下版本开始:

5.1

sort

public reactor.core.publisher.Flux<String> sort(String key)

Sort the elements in a list, set or sorted set.

指定者:

sort 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

V array-reply list of sorted elements.

sort

@Deprecated
public reactor.core.publisher.Mono<Long> sort(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key)

已过时。

Sort the elements in a list, set or sorted set.

指定者:

sort 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

返回:

Long number of values.

sort

public reactor.core.publisher.Flux<String> sort(String key,
 io.lettuce.core.SortArgs sortArgs)

Sort the elements in a list, set or sorted set.

指定者:

sort 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

sortArgs - sort arguments.

返回:

V array-reply list of sorted elements.

sort

@Deprecated
public reactor.core.publisher.Mono<Long> sort(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.SortArgs sortArgs)

已过时。

Sort the elements in a list, set or sorted set.

指定者:

sort 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

sortArgs - sort arguments.

返回:

Long number of values.

sortReadOnly

public reactor.core.publisher.Flux<String> sortReadOnly(String s)

指定者:

sortReadOnly 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

sortReadOnly

@Deprecated
public reactor.core.publisher.Mono<Long> sortReadOnly(io.lettuce.core.output.ValueStreamingChannel<String> valueStreamingChannel,
 String s)

已过时。

指定者:

sortReadOnly 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

valueStreamingChannel -

s -

sortReadOnly

public reactor.core.publisher.Flux<String> sortReadOnly(String s,
 io.lettuce.core.SortArgs sortArgs)

指定者:

sortReadOnly 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

sortReadOnly

@Deprecated
public reactor.core.publisher.Mono<Long> sortReadOnly(io.lettuce.core.output.ValueStreamingChannel<String> valueStreamingChannel,
 String s,
 io.lettuce.core.SortArgs sortArgs)

已过时。

指定者:

sortReadOnly 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

valueStreamingChannel -

s -

sortArgs -

sortStore

public reactor.core.publisher.Mono<Long> sortStore(String key,
 io.lettuce.core.SortArgs sortArgs,
 String destination)

Sort the elements in a list, set or sorted set.

指定者:

sortStore 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

sortArgs - sort arguments.

destination - the destination key to store sort results.

返回:

Long number of values.

eval

public <T> reactor.core.publisher.Flux<T> eval(String script,
 io.lettuce.core.ScriptOutputType type,
 String... keys)

Execute a Lua script server side.

指定者:

eval 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

参数:

script - Lua 5.1 script.

type - output type.

keys - key names.

返回:

script result.

eval

public <T> reactor.core.publisher.Flux<T> eval(byte[] bytes,
 io.lettuce.core.ScriptOutputType scriptOutputType,
 String... strings)

指定者:

eval 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

eval

public <T> reactor.core.publisher.Flux<T> eval(String script,
 io.lettuce.core.ScriptOutputType type,
 String[] keys,
 String... values)

Execute a Lua script server side.

指定者:

eval 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

参数:

script - Lua 5.1 script.

type - the type.

keys - the keys.

values - the values.

返回:

script result.

eval

public <T> reactor.core.publisher.Flux<T> eval(byte[] bytes,
 io.lettuce.core.ScriptOutputType scriptOutputType,
 String[] strings,
 String... strings2)

指定者:

eval 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

evalReadOnly

public <T> reactor.core.publisher.Flux<T> evalReadOnly(byte[] bytes,
 io.lettuce.core.ScriptOutputType scriptOutputType,
 String[] strings,
 String... strings2)

指定者:

evalReadOnly 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

evalsha

public <T> reactor.core.publisher.Flux<T> evalsha(String digest,
 io.lettuce.core.ScriptOutputType type,
 String... keys)

Evaluates a script cached on the server side by its SHA1 digest.

指定者:

evalsha 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

参数:

digest - SHA1 of the script.

type - the type.

keys - the keys.

返回:

script result.

evalsha

public <T> reactor.core.publisher.Flux<T> evalsha(String digest,
 io.lettuce.core.ScriptOutputType type,
 String[] keys,
 String... values)

Execute a Lua script server side.

指定者:

evalsha 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

参数:

digest - SHA1 of the script.

type - the type.

keys - the keys.

values - the values.

返回:

script result.

evalshaReadOnly

public <T> reactor.core.publisher.Flux<T> evalshaReadOnly(String s,
 io.lettuce.core.ScriptOutputType scriptOutputType,
 String[] strings,
 String... strings2)

指定者:

evalshaReadOnly 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

scriptExists

public reactor.core.publisher.Flux<Boolean> scriptExists(String... digests)

Check existence of scripts in the script cache.

指定者:

scriptExists 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

参数:

digests - script digests.

返回:

Boolean array-reply The command returns an array of integers that correspond to the specified SHA1 digest arguments. For every corresponding SHA1 digest of a script that actually exists in the script cache, an 1 is returned, otherwise 0 is returned.

scriptFlush

public reactor.core.publisher.Mono<String> scriptFlush()

Remove all the scripts from the script cache on all cluster nodes.

指定者:

scriptFlush 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scriptFlush 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

返回:

String simple-string-reply.

scriptFlush

public reactor.core.publisher.Mono<String> scriptFlush(io.lettuce.core.FlushMode flushMode)

指定者:

scriptFlush 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

scriptKill

public reactor.core.publisher.Mono<String> scriptKill()

Kill the script currently in execution on all cluster nodes. This call does not fail even if no scripts are running.

指定者:

scriptKill 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scriptKill 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

返回:

String simple-string-reply, always OK.

scriptLoad

public reactor.core.publisher.Mono<String> scriptLoad(String script)

Load the specified Lua script into the script cache on all cluster nodes.

指定者:

scriptLoad 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scriptLoad 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

参数:

script - script content.

返回:

String bulk-string-reply This command returns the SHA1 digest of the script added into the script cache.

scriptLoad

public reactor.core.publisher.Mono<String> scriptLoad(byte[] bytes)

指定者:

scriptLoad 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scriptLoad 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

digest

public String digest(String script)

Create a SHA1 digest from a Lua script.

指定者:

digest 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

参数:

script - script content.

返回:

the SHA1 value.

digest

public String digest(byte[] bytes)

指定者:

digest 在接口中 io.lettuce.core.api.reactive.RedisScriptingReactiveCommands<String,String>

shutdown

public reactor.core.publisher.Mono<Void> shutdown(boolean save)

Synchronously save the dataset to disk and then shut down all nodes of the cluster.

指定者:

shutdown 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

shutdown 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

save - true force save operation.

shutdown

public reactor.core.publisher.Mono<Void> shutdown(io.lettuce.core.ShutdownArgs shutdownArgs)

指定者:

shutdown 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

slaveof

public reactor.core.publisher.Mono<String> slaveof(String host,
 int port)

Make the server a replica of another instance, or promote it as master.

指定者:

slaveof 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

host - the host type: string.

port - the port type: string.

返回:

String simple-string-reply.

slaveofNoOne

public reactor.core.publisher.Mono<String> slaveofNoOne()

Promote server as master.

指定者:

slaveofNoOne 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply.

slowlogGet

public reactor.core.publisher.Flux<Object> slowlogGet()

Read the slow log.

指定者:

slowlogGet 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

Object deeply nested multi bulk replies.

slowlogGet

public reactor.core.publisher.Flux<Object> slowlogGet(int count)

Read the slow log.

指定者:

slowlogGet 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

参数:

count - the count.

返回:

Object deeply nested multi bulk replies.

slowlogLen

public reactor.core.publisher.Mono<Long> slowlogLen()

Obtaining the current length of the slow log.

指定者:

slowlogLen 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

Long length of the slow log.

slowlogReset

public reactor.core.publisher.Mono<String> slowlogReset()

Resetting the slow log.

指定者:

slowlogReset 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

String simple-string-reply The commands returns OK on success.

time

public reactor.core.publisher.Flux<String> time()

Return the current server time.

指定者:

time 在接口中 io.lettuce.core.api.reactive.RedisServerReactiveCommands<String,String>

返回:

V array-reply specifically:

A multi bulk reply containing two elements:

unix time in seconds. microseconds.

scan

public reactor.core.publisher.Mono<io.lettuce.core.KeyScanCursor<String>> scan()

Incrementally iterate the keys space over the whole Cluster.

指定者:

scan 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scan 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

返回:

KeyScanCursor<K> scan cursor.

scan

public reactor.core.publisher.Mono<io.lettuce.core.KeyScanCursor<String>> scan(io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate the keys space over the whole Cluster.

指定者:

scan 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scan 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

scanArgs - scan arguments.

返回:

KeyScanCursor<K> scan cursor.

scan

public reactor.core.publisher.Mono<io.lettuce.core.KeyScanCursor<String>> scan(io.lettuce.core.ScanCursor scanCursor,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate the keys space over the whole Cluster.

指定者:

scan 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scan 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

scanCursor - cursor to resume the scan. It's required to reuse the scanCursor instance from the previous scan() call.

scanArgs - scan arguments.

返回:

KeyScanCursor<K> scan cursor.

scan

public reactor.core.publisher.Mono<io.lettuce.core.KeyScanCursor<String>> scan(io.lettuce.core.ScanCursor scanCursor)

Incrementally iterate the keys space over the whole Cluster.

指定者:

scan 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scan 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

scanCursor - cursor to resume the scan. It's required to reuse the scanCursor instance from the previous scan() call.

返回:

KeyScanCursor<K> scan cursor.

scan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> scan(io.lettuce.core.output.KeyStreamingChannel<String> channel)

Incrementally iterate the keys space over the whole Cluster.

指定者:

scan 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scan 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every key.

返回:

StreamScanCursor scan cursor.

scan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> scan(io.lettuce.core.output.KeyStreamingChannel<String> channel,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate the keys space over the whole Cluster.

指定者:

scan 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scan 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every key.

scanArgs - scan arguments.

返回:

StreamScanCursor scan cursor.

scan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> scan(io.lettuce.core.output.KeyStreamingChannel<String> channel,
 io.lettuce.core.ScanCursor scanCursor,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate the keys space over the whole Cluster.

指定者:

scan 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scan 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every key.

scanCursor - cursor to resume the scan. It's required to reuse the scanCursor instance from the previous scan() call.

scanArgs - scan arguments.

返回:

StreamScanCursor scan cursor.

scan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> scan(io.lettuce.core.output.KeyStreamingChannel<String> channel,
 io.lettuce.core.ScanCursor scanCursor)

Incrementally iterate the keys space over the whole Cluster.

指定者:

scan 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

scan 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every key.

scanCursor - cursor to resume the scan. It's required to reuse the scanCursor instance from the previous scan() call.

返回:

StreamScanCursor scan cursor.

touch

public reactor.core.publisher.Mono<Long> touch(String... keys)

Touch one or more keys with pipelining. Touch sets the last accessed time for a key. Non-exsitent keys wont get created. Cross-slot keys will result in multiple calls to the particular cluster nodes.

指定者:

touch 在接口中 io.lettuce.core.cluster.api.reactive.RedisAdvancedClusterReactiveCommands<String,String>

指定者:

touch 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

keys - the keys.

返回:

Long integer-reply the number of found keys.

ttl

public reactor.core.publisher.Mono<Long> ttl(String key)

Get the time to live for a key.

指定者:

ttl 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply TTL in seconds, or a negative value in order to signal an error (see the description above).

type

public reactor.core.publisher.Mono<String> type(String key)

Determine the type stored at key.

指定者:

type 在接口中 io.lettuce.core.api.reactive.RedisKeyReactiveCommands<String,String>

参数:

key - the key.

返回:

String simple-string-reply type of key, or none when key does not exist.

geoadd

public reactor.core.publisher.Mono<Long> geoadd(String key,
 double longitude,
 double latitude,
 String member)

Single geo add.

指定者:

geoadd 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

longitude - the longitude coordinate according to WGS84.

latitude - the latitude coordinate according to WGS84.

member - the member to add.

返回:

Long integer-reply the number of elements that were added to the set.

geoadd

public reactor.core.publisher.Mono<Long> geoadd(String s,
 double v,
 double v1,
 String v2,
 io.lettuce.core.GeoAddArgs geoAddArgs)

指定者:

geoadd 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

geoadd

public reactor.core.publisher.Mono<Long> geoadd(String key,
 Object... lngLatMember)

Multi geo add.

指定者:

geoadd 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

lngLatMember - triplets of double longitude, double latitude and V member.

返回:

Long integer-reply the number of elements that were added to the set.

geoadd

public reactor.core.publisher.Mono<Long> geoadd(String s,
 io.lettuce.core.GeoValue<String>... geoValues)

指定者:

geoadd 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

geoadd

public reactor.core.publisher.Mono<Long> geoadd(String s,
 io.lettuce.core.GeoAddArgs geoAddArgs,
 Object... objects)

指定者:

geoadd 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

geoadd

public reactor.core.publisher.Mono<Long> geoadd(String s,
 io.lettuce.core.GeoAddArgs geoAddArgs,
 io.lettuce.core.GeoValue<String>... geoValues)

指定者:

geoadd 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

geohash

public reactor.core.publisher.Flux<io.lettuce.core.Value<String>> geohash(String key,
 String... members)

Retrieve Geohash strings representing the position of one or more elements in a sorted set value representing a geospatial index.

指定者:

geohash 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

members - the members.

返回:

bulk reply Geohash strings in the order of members. Returns null if a member is not found.

georadius

public reactor.core.publisher.Flux<String> georadius(String key,
 double longitude,
 double latitude,
 double distance,
 io.lettuce.core.GeoArgs.Unit unit)

Retrieve members selected by distance with the center of longitude and latitude.

指定者:

georadius 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

longitude - the longitude coordinate according to WGS84.

latitude - the latitude coordinate according to WGS84.

distance - radius distance.

unit - distance unit.

返回:

bulk reply.

georadius

public reactor.core.publisher.Flux<io.lettuce.core.GeoWithin<String>> georadius(String key,
 double longitude,
 double latitude,
 double distance,
 io.lettuce.core.GeoArgs.Unit unit,
 io.lettuce.core.GeoArgs geoArgs)

Retrieve members selected by distance with the center of longitude and latitude.

指定者:

georadius 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

longitude - the longitude coordinate according to WGS84.

latitude - the latitude coordinate according to WGS84.

distance - radius distance.

unit - distance unit.

geoArgs - args to control the result.

返回:

nested multi-bulk reply. The GeoWithin contains only fields which were requested by GeoArgs.

georadius

public reactor.core.publisher.Mono<Long> georadius(String key,
 double longitude,
 double latitude,
 double distance,
 io.lettuce.core.GeoArgs.Unit unit,
 io.lettuce.core.GeoRadiusStoreArgs<String> geoRadiusStoreArgs)

Perform a {@link #(Object, double, double, double, GeoArgs.Unit, GeoArgs)} query and store the results in a sorted set.

指定者:

georadius 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

longitude - the longitude coordinate according to WGS84.

latitude - the latitude coordinate according to WGS84.

distance - radius distance.

unit - distance unit.

geoRadiusStoreArgs - args to store either the resulting elements with their distance or the resulting elements with their locations a sorted set.

返回:

Long integer-reply the number of elements in the result.

georadiusbymember

public reactor.core.publisher.Flux<String> georadiusbymember(String key,
 String member,
 double distance,
 io.lettuce.core.GeoArgs.Unit unit)

Retrieve members selected by distance with the center of member. The member itself is always contained in the results.

指定者:

georadiusbymember 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

member - reference member.

distance - radius distance.

unit - distance unit.

返回:

set of members.

georadiusbymember

public reactor.core.publisher.Flux<io.lettuce.core.GeoWithin<String>> georadiusbymember(String key,
 String member,
 double distance,
 io.lettuce.core.GeoArgs.Unit unit,
 io.lettuce.core.GeoArgs geoArgs)

Retrieve members selected by distance with the center of member. The member itself is always contained in the results.

指定者:

georadiusbymember 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

member - reference member.

distance - radius distance.

unit - distance unit.

geoArgs - args to control the result.

返回:

nested multi-bulk reply. The GeoWithin contains only fields which were requested by GeoArgs.

georadiusbymember

public reactor.core.publisher.Mono<Long> georadiusbymember(String key,
 String member,
 double distance,
 io.lettuce.core.GeoArgs.Unit unit,
 io.lettuce.core.GeoRadiusStoreArgs<String> geoRadiusStoreArgs)

Perform a {@link #(Object, Object, double, GeoArgs.Unit, GeoArgs)} query and store the results in a sorted set.

指定者:

georadiusbymember 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

member - reference member.

distance - radius distance.

unit - distance unit.

geoRadiusStoreArgs - args to store either the resulting elements with their distance or the resulting elements with their locations a sorted set.

返回:

Long integer-reply the number of elements in the result.

geosearch

public reactor.core.publisher.Flux<String> geosearch(String s,
 io.lettuce.core.GeoSearch.GeoRef<String> geoRef,
 io.lettuce.core.GeoSearch.GeoPredicate geoPredicate)

指定者:

geosearch 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

geosearch

public reactor.core.publisher.Flux<io.lettuce.core.GeoWithin<String>> geosearch(String s,
 io.lettuce.core.GeoSearch.GeoRef<String> geoRef,
 io.lettuce.core.GeoSearch.GeoPredicate geoPredicate,
 io.lettuce.core.GeoArgs geoArgs)

指定者:

geosearch 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

geosearchstore

public reactor.core.publisher.Mono<Long> geosearchstore(String s,
 String k1,
 io.lettuce.core.GeoSearch.GeoRef<String> geoRef,
 io.lettuce.core.GeoSearch.GeoPredicate geoPredicate,
 io.lettuce.core.GeoArgs geoArgs,
 boolean b)

指定者:

geosearchstore 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

geopos

public reactor.core.publisher.Flux<io.lettuce.core.Value<io.lettuce.core.GeoCoordinates>> geopos(String key,
 String... members)

Get geo coordinates for the members.

指定者:

geopos 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

members - the members.

返回:

a list of GeoCoordinatess representing the x,y position of each element specified in the arguments. For missing elements null is returned.

geodist

public reactor.core.publisher.Mono<Double> geodist(String key,
 String from,
 String to,
 io.lettuce.core.GeoArgs.Unit unit)

Retrieve distance between points from and to. If one or more elements are missing null is returned. Default in meters by, otherwise according to unit

指定者:

geodist 在接口中 io.lettuce.core.api.reactive.RedisGeoReactiveCommands<String,String>

参数:

key - the key of the geo set.

from - from member.

to - to member.

unit - distance unit.

返回:

distance between points from and to. If one or more elements are missing null is returned.

pfadd

public reactor.core.publisher.Mono<Long> pfadd(String key,
 String... values)

Adds the specified elements to the specified HyperLogLog.

指定者:

pfadd 在接口中 io.lettuce.core.api.reactive.RedisHLLReactiveCommands<String,String>

参数:

key - the key.

values - the values.

返回:

Long integer-reply specifically:

1 if at least 1 HyperLogLog internal register was altered. 0 otherwise.

pfmerge

public reactor.core.publisher.Mono<String> pfmerge(String destkey,
 String... sourcekeys)

Merge N different HyperLogLogs into a single one.

指定者:

pfmerge 在接口中 io.lettuce.core.api.reactive.RedisHLLReactiveCommands<String,String>

参数:

destkey - the destination key.

sourcekeys - the source key.

返回:

String simple-string-reply The command just returns OK.

pfcount

public reactor.core.publisher.Mono<Long> pfcount(String... keys)

Return the approximated cardinality of the set(s) observed by the HyperLogLog at key(s).

指定者:

pfcount 在接口中 io.lettuce.core.api.reactive.RedisHLLReactiveCommands<String,String>

参数:

keys - the keys.

返回:

Long integer-reply specifically:

The approximated number of unique elements observed via PFADD.

hdel

public reactor.core.publisher.Mono<Long> hdel(String key,
 String... fields)

Delete one or more hash fields.

指定者:

hdel 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

fields - the field type: key.

返回:

Long integer-reply the number of fields that were removed from the hash, not including specified but non existing fields.

hexists

public reactor.core.publisher.Mono<Boolean> hexists(String key,
 String field)

Determine if a hash field exists.

指定者:

hexists 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

field - the field type: key.

返回:

true if the hash contains field. false if the hash does not contain field, or key does not exist.

hget

public reactor.core.publisher.Mono<String> hget(String key,
 String field)

Get the value of a hash field.

指定者:

hget 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

field - the field type: key.

返回:

V bulk-string-reply the value associated with field, or null when field is not present in the hash or key does not exist.

hincrby

public reactor.core.publisher.Mono<Long> hincrby(String key,
 String field,
 long amount)

Increment the integer value of a hash field by the given number.

指定者:

hincrby 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

field - the field type: key.

amount - the increment type: long.

返回:

Long integer-reply the value at field after the increment operation.

hincrbyfloat

public reactor.core.publisher.Mono<Double> hincrbyfloat(String key,
 String field,
 double amount)

Increment the float value of a hash field by the given amount.

指定者:

hincrbyfloat 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

field - the field type: key.

amount - the increment type: double.

返回:

Double bulk-string-reply the value of field after the increment.

hgetall

public reactor.core.publisher.Flux<io.lettuce.core.KeyValue<String,String>> hgetall(String s)

指定者:

hgetall 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

hgetall

public reactor.core.publisher.Mono<Long> hgetall(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel,
 String key)

Stream over all the fields and values in a hash.

指定者:

hgetall 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

channel - the channel.

key - the key.

返回:

Long count of the keys.

hkeys

public reactor.core.publisher.Flux<String> hkeys(String key)

Get all the fields in a hash.

指定者:

hkeys 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

返回:

K array-reply list of fields in the hash, or an empty list when key does not exist.

hkeys

public reactor.core.publisher.Mono<Long> hkeys(io.lettuce.core.output.KeyStreamingChannel<String> channel,
 String key)

Stream over all the fields in a hash.

指定者:

hkeys 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

channel - the channel.

key - the key.

返回:

Long count of the keys.

hlen

public reactor.core.publisher.Mono<Long> hlen(String key)

Get the number of fields in a hash.

指定者:

hlen 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply number of fields in the hash, or 0 when key does not exist.

hmget

public reactor.core.publisher.Flux<io.lettuce.core.KeyValue<String,String>> hmget(String key,
 String... fields)

Get the values of all the given hash fields.

指定者:

hmget 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

fields - the field type: key.

返回:

V array-reply list of values associated with the given fields, in the same.

hmget

public reactor.core.publisher.Mono<Long> hmget(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel,
 String key,
 String... fields)

Stream over the values of all the given hash fields.

指定者:

hmget 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

channel - the channel.

key - the key.

fields - the fields.

返回:

Long count of the keys.

hmset

public reactor.core.publisher.Mono<String> hmset(String key,
 Map<String,String> map)

Set multiple hash fields to multiple values.

指定者:

hmset 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

map - the null.

返回:

String simple-string-reply.

hrandfield

public reactor.core.publisher.Mono<String> hrandfield(String s)

指定者:

hrandfield 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

hrandfield

public reactor.core.publisher.Flux<String> hrandfield(String s,
 long l)

指定者:

hrandfield 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

hrandfieldWithvalues

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>> hrandfieldWithvalues(String s)

指定者:

hrandfieldWithvalues 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

hrandfieldWithvalues

public reactor.core.publisher.Flux<io.lettuce.core.KeyValue<String,String>> hrandfieldWithvalues(String s,
 long l)

指定者:

hrandfieldWithvalues 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

hscan

public reactor.core.publisher.Mono<io.lettuce.core.MapScanCursor<String,String>> hscan(String key)

Incrementally iterate hash fields and associated values.

指定者:

hscan 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

返回:

MapScanCursor<K, V> map scan cursor.

hscan

public reactor.core.publisher.Mono<io.lettuce.core.MapScanCursor<String,String>> hscan(String key,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate hash fields and associated values.

指定者:

hscan 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

scanArgs - scan arguments.

返回:

MapScanCursor<K, V> map scan cursor.

hscan

public reactor.core.publisher.Mono<io.lettuce.core.MapScanCursor<String,String>> hscan(String key,
 io.lettuce.core.ScanCursor scanCursor,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate hash fields and associated values.

指定者:

hscan 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

scanArgs - scan arguments.

返回:

MapScanCursor<K, V> map scan cursor.

hscan

public reactor.core.publisher.Mono<io.lettuce.core.MapScanCursor<String,String>> hscan(String key,
 io.lettuce.core.ScanCursor scanCursor)

Incrementally iterate hash fields and associated values.

指定者:

hscan 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

返回:

MapScanCursor<K, V> map scan cursor.

hscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> hscan(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel,
 String key)

Incrementally iterate hash fields and associated values.

指定者:

hscan 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every key-value pair.

key - the key.

返回:

StreamScanCursor scan cursor.

hscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> hscan(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel,
 String key,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate hash fields and associated values.

指定者:

hscan 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every key-value pair.

key - the key.

scanArgs - scan arguments.

返回:

StreamScanCursor scan cursor.

hscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> hscan(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel,
 String key,
 io.lettuce.core.ScanCursor scanCursor,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate hash fields and associated values.

指定者:

hscan 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every key-value pair.

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

scanArgs - scan arguments.

返回:

StreamScanCursor scan cursor.

hscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> hscan(io.lettuce.core.output.KeyValueStreamingChannel<String,String> channel,
 String key,
 io.lettuce.core.ScanCursor scanCursor)

Incrementally iterate hash fields and associated values.

指定者:

hscan 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every key-value pair.

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

返回:

StreamScanCursor scan cursor.

hset

public reactor.core.publisher.Mono<Boolean> hset(String key,
 String field,
 String value)

Set the string value of a hash field.

指定者:

hset 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

field - the field type: key.

value - the value.

返回:

Boolean integer-reply specifically:

true if field is a new field in the hash and value was set. false if field already exists in the hash and the value was updated.

hset

public reactor.core.publisher.Mono<Long> hset(String key,
 Map<String,String> map)

Set multiple hash fields to multiple values.

指定者:

hset 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key of the hash.

map - the field/value pairs to update.

返回:

Long integer-reply: the number of fields that were added.

从以下版本开始:

5.3

hsetnx

public reactor.core.publisher.Mono<Boolean> hsetnx(String key,
 String field,
 String value)

Set the value of a hash field, only if the field does not exist.

指定者:

hsetnx 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

field - the field type: key.

value - the value.

返回:

Boolean integer-reply specifically:

1 if field is a new field in the hash and value was set. 0 if field already exists in the hash and no operation was performed.

hstrlen

public reactor.core.publisher.Mono<Long> hstrlen(String key,
 String field)

Get the string length of the field value in a hash.

指定者:

hstrlen 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

field - the field type: key.

返回:

Long integer-reply the string length of the field value, or 0 when field is not present in the hash or key does not exist at all.

hvals

public reactor.core.publisher.Flux<String> hvals(String key)

Get all the values in a hash.

指定者:

hvals 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

key - the key.

返回:

V array-reply list of values in the hash, or an empty list when key does not exist.

hvals

public reactor.core.publisher.Mono<Long> hvals(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key)

Stream over all the values in a hash.

指定者:

hvals 在接口中 io.lettuce.core.api.reactive.RedisHashReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

返回:

Long count of the keys.

blmove

public reactor.core.publisher.Mono<String> blmove(String s,
 String k1,
 io.lettuce.core.LMoveArgs lMoveArgs,
 long l)

指定者:

blmove 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

blmove

public reactor.core.publisher.Mono<String> blmove(String s,
 String k1,
 io.lettuce.core.LMoveArgs lMoveArgs,
 double v)

指定者:

blmove 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

blmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<String>>> blmpop(long l,
 io.lettuce.core.LMPopArgs lmPopArgs,
 String... strings)

指定者:

blmpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

blmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<String>>> blmpop(double v,
 io.lettuce.core.LMPopArgs lmPopArgs,
 String... strings)

指定者:

blmpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

blpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>> blpop(long timeout,
 String... keys)

Remove and get the first element in a list, or block until one is available.

指定者:

blpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

timeout - the timeout in seconds.

keys - the keys.

返回:

KeyValue<K,V> array-reply specifically:

A null multi-bulk when no element could be popped and the timeout expired. A two-element multi-bulk with the first element being the name of the key where an element was popped and the second element being the value of the popped element.

blpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>> blpop(double v,
 String... strings)

指定者:

blpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

brpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>> brpop(long timeout,
 String... keys)

Remove and get the last element in a list, or block until one is available.

指定者:

brpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

timeout - the timeout in seconds.

keys - the keys.

返回:

KeyValue<K,V> array-reply specifically:

A null multi-bulk when no element could be popped and the timeout expired. A two-element multi-bulk with the first element being the name of the key where an element was popped and the second element being the value of the popped element.

brpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,String>> brpop(double v,
 String... strings)

指定者:

brpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

brpoplpush

public reactor.core.publisher.Mono<String> brpoplpush(long timeout,
 String source,
 String destination)

Pop a value from a list, push it to another list and return it; or block until one is available.

指定者:

brpoplpush 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

timeout - the timeout in seconds.

source - the source key.

destination - the destination type: key.

返回:

V bulk-string-reply the element being popped from source and pushed to destination. If timeout is reached, a.

brpoplpush

public reactor.core.publisher.Mono<String> brpoplpush(double v,
 String s,
 String k1)

指定者:

brpoplpush 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

lindex

public reactor.core.publisher.Mono<String> lindex(String key,
 long index)

Get an element from a list by its index.

指定者:

lindex 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

index - the index type: long.

返回:

V bulk-string-reply the requested element, or null when index is out of range.

linsert

public reactor.core.publisher.Mono<Long> linsert(String key,
 boolean before,
 String pivot,
 String value)

Insert an element before or after another element in a list.

指定者:

linsert 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

before - the before.

pivot - the pivot.

value - the value.

返回:

Long integer-reply the length of the list after the insert operation, or -1 when the value pivot was not found.

llen

public reactor.core.publisher.Mono<Long> llen(String key)

Get the length of a list.

指定者:

llen 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply the length of the list at key.

lmove

public reactor.core.publisher.Mono<String> lmove(String s,
 String k1,
 io.lettuce.core.LMoveArgs lMoveArgs)

指定者:

lmove 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

lmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<String>>> lmpop(io.lettuce.core.LMPopArgs lmPopArgs,
 String... strings)

指定者:

lmpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

lpop

public reactor.core.publisher.Mono<String> lpop(String key)

Remove and get the first element in a list.

指定者:

lpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

返回:

V bulk-string-reply the value of the first element, or null when key does not exist.

lpop

public reactor.core.publisher.Flux<String> lpop(String s,
 long l)

指定者:

lpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

lpos

public reactor.core.publisher.Mono<Long> lpos(String key,
 String value)

Return the index of matching elements inside a Redis list. By default, when no options are given, it will scan the list from head to tail, looking for the first match of "element". If the element is found, its index (the zero-based position in the list) is returned. Otherwise, if no match is found, null is returned. The returned elements indexes are always referring to what RedisListReactiveCommands.lindex(Object, long) would return. So first element from head is 0, and so forth.

指定者:

lpos 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

value - the element to search for.

返回:

V integer-reply representing the matching element, or null if there is no match.

从以下版本开始:

5.3.2

lpos

public reactor.core.publisher.Mono<Long> lpos(String key,
 String value,
 io.lettuce.core.LPosArgs args)

Return the index of matching elements inside a Redis list. By default, when no options are given, it will scan the list from head to tail, looking for the first match of "element". If the element is found, its index (the zero-based position in the list) is returned. Otherwise, if no match is found, null is returned. The returned elements indexes are always referring to what RedisListReactiveCommands.lindex(Object, long) would return. So first element from head is 0, and so forth.

指定者:

lpos 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

value - the element to search for.

args - command arguments to configureFIRST and MAXLEN options.

返回:

V integer-reply representing the matching element, or null if there is no match.

从以下版本开始:

5.3.2

lpos

public reactor.core.publisher.Flux<Long> lpos(String key,
 String value,
 int count)

Return the index of matching elements inside a Redis list using the COUNT option. By default, when no options are given, it will scan the list from head to tail, looking for the first match of "element". The returned elements indexes are always referring to what RedisListReactiveCommands.lindex(Object, long) would return. So first element from head is 0, and so forth.

指定者:

lpos 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

value - the element to search for.

count - limit the number of matches.

返回:

V integer-reply representing the matching elements, or empty if there is no match.

从以下版本开始:

5.3.2

lpos

public reactor.core.publisher.Flux<Long> lpos(String key,
 String value,
 int count,
 io.lettuce.core.LPosArgs args)

Return the index of matching elements inside a Redis list using the COUNT option. By default, when no options are given, it will scan the list from head to tail, looking for the first match of "element". The returned elements indexes are always referring to what RedisListReactiveCommands.lindex(Object, long) would return. So first element from head is 0, and so forth.

指定者:

lpos 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

value - the element to search for.

count - limit the number of matches.

args - command arguments to configureFIRST and MAXLEN options.

返回:

V integer-reply representing the matching elements, or empty if there is no match.

从以下版本开始:

5.3.2

lpush

public reactor.core.publisher.Mono<Long> lpush(String key,
 String... values)

Prepend one or multiple values to a list.

指定者:

lpush 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

values - the value.

返回:

Long integer-reply the length of the list after the push operations.

lpushx

public reactor.core.publisher.Mono<Long> lpushx(String key,
 String... values)

Prepend values to a list, only if the list exists.

指定者:

lpushx 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

values - the values.

返回:

Long integer-reply the length of the list after the push operation.

lrange

public reactor.core.publisher.Flux<String> lrange(String key,
 long start,
 long stop)

Get a range of elements from a list.

指定者:

lrange 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

start - the start type: long.

stop - the stop type: long.

返回:

V array-reply list of elements in the specified range.

lrange

public reactor.core.publisher.Mono<Long> lrange(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 long start,
 long stop)

Get a range of elements from a list.

指定者:

lrange 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

channel - the channel.

key - the key.

start - the start type: long.

stop - the stop type: long.

返回:

Long count of elements in the specified range.

lrem

public reactor.core.publisher.Mono<Long> lrem(String key,
 long count,
 String value)

Remove elements from a list.

指定者:

lrem 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

count - the count type: long.

value - the value.

返回:

Long integer-reply the number of removed elements.

lset

public reactor.core.publisher.Mono<String> lset(String key,
 long index,
 String value)

Set the value of an element in a list by its index.

指定者:

lset 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

index - the index type: long.

value - the value.

返回:

String simple-string-reply.

ltrim

public reactor.core.publisher.Mono<String> ltrim(String key,
 long start,
 long stop)

Trim a list to the specified range.

指定者:

ltrim 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

start - the start type: long.

stop - the stop type: long.

返回:

String simple-string-reply.

rpop

public reactor.core.publisher.Mono<String> rpop(String key)

Remove and get the last element in a list.

指定者:

rpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

返回:

V bulk-string-reply the value of the last element, or null when key does not exist.

rpop

public reactor.core.publisher.Flux<String> rpop(String s,
 long l)

指定者:

rpop 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

rpoplpush

public reactor.core.publisher.Mono<String> rpoplpush(String source,
 String destination)

Remove the last element in a list, append it to another list and return it.

指定者:

rpoplpush 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

source - the source key.

destination - the destination type: key.

返回:

V bulk-string-reply the element being popped and pushed.

rpush

public reactor.core.publisher.Mono<Long> rpush(String key,
 String... values)

Append one or multiple values to a list.

指定者:

rpush 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

values - the value.

返回:

Long integer-reply the length of the list after the push operation.

rpushx

public reactor.core.publisher.Mono<Long> rpushx(String key,
 String... values)

Append values to a list, only if the list exists.

指定者:

rpushx 在接口中 io.lettuce.core.api.reactive.RedisListReactiveCommands<String,String>

参数:

key - the key.

values - the values.

返回:

Long integer-reply the length of the list after the push operation.

sadd

public reactor.core.publisher.Mono<Long> sadd(String key,
 String... members)

Add one or more members to a set.

指定者:

sadd 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

members - the member type: value.

返回:

Long integer-reply the number of elements that were added to the set, not including all the elements already present into the set.

scard

public reactor.core.publisher.Mono<Long> scard(String key)

Get the number of members in a set.

指定者:

scard 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply the cardinality (number of elements) of the set, or false if key does not exist.

sdiff

public reactor.core.publisher.Flux<String> sdiff(String... keys)

Subtract multiple sets.

指定者:

sdiff 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

keys - the key.

返回:

V array-reply list with members of the resulting set.

sdiff

public reactor.core.publisher.Mono<Long> sdiff(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String... keys)

Subtract multiple sets.

指定者:

sdiff 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - the channel.

keys - the keys.

返回:

Long count of members of the resulting set.

sdiffstore

public reactor.core.publisher.Mono<Long> sdiffstore(String destination,
 String... keys)

Subtract multiple sets and store the resulting set in a key.

指定者:

sdiffstore 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

destination - the destination type: key.

keys - the key.

返回:

Long integer-reply the number of elements in the resulting set.

sinter

public reactor.core.publisher.Flux<String> sinter(String... keys)

Intersect multiple sets.

指定者:

sinter 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

keys - the key.

返回:

V array-reply list with members of the resulting set.

sinter

@Deprecated
public reactor.core.publisher.Mono<Long> sinter(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String... keys)

已过时。

Intersect multiple sets.

指定者:

sinter 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - the channel.

keys - the keys.

返回:

Long count of members of the resulting set.

sintercard

public reactor.core.publisher.Mono<Long> sintercard(String... strings)

指定者:

sintercard 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

sintercard

public reactor.core.publisher.Mono<Long> sintercard(long l,
 String... strings)

指定者:

sintercard 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

sinterstore

public reactor.core.publisher.Mono<Long> sinterstore(String destination,
 String... keys)

Intersect multiple sets and store the resulting set in a key.

指定者:

sinterstore 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

destination - the destination type: key.

keys - the key.

返回:

Long integer-reply the number of elements in the resulting set.

sismember

public reactor.core.publisher.Mono<Boolean> sismember(String key,
 String member)

Determine if a given value is a member of a set.

指定者:

sismember 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

member - the member type: value.

返回:

Boolean integer-reply specifically:

true if the element is a member of the set. false if the element is not a member of the set, or if key does not exist.

smove

public reactor.core.publisher.Mono<Boolean> smove(String source,
 String destination,
 String member)

Move a member from one set to another.

指定者:

smove 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

source - the source key.

destination - the destination type: key.

member - the member type: value.

返回:

Boolean integer-reply specifically:

true if the element is moved. false if the element is not a member of source and no operation was performed.

smembers

public reactor.core.publisher.Flux<String> smembers(String key)

Get all the members in a set.

指定者:

smembers 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

返回:

V array-reply all elements of the set.

smembers

@Deprecated
public reactor.core.publisher.Mono<Long> smembers(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key)

已过时。

Get all the members in a set.

指定者:

smembers 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - the channel.

key - the keys.

返回:

Long count of members of the resulting set.

smismember

public reactor.core.publisher.Flux<Boolean> smismember(String s,
 String... strings)

指定者:

smismember 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

spop

public reactor.core.publisher.Mono<String> spop(String key)

Remove and return a random member from a set.

指定者:

spop 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

返回:

V bulk-string-reply the removed element, or null when key does not exist.

spop

public reactor.core.publisher.Flux<String> spop(String key,
 long count)

Remove and return one or multiple random members from a set.

指定者:

spop 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

count - number of members to pop.

返回:

V bulk-string-reply the removed element, or null when key does not exist.

srandmember

public reactor.core.publisher.Mono<String> srandmember(String key)

Get one random member from a set.

指定者:

srandmember 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

返回:

V bulk-string-reply without the additional count argument the command returns a Bulk Reply with the randomly selected element, or null when key does not exist.

srandmember

public reactor.core.publisher.Flux<String> srandmember(String key,
 long count)

Get one or multiple random members from a set.

指定者:

srandmember 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

count - the count type: long.

返回:

V bulk-string-reply without the additional count argument the command returns a Bulk Reply with the randomly selected element, or null when key does not exist.

srandmember

@Deprecated
public reactor.core.publisher.Mono<Long> srandmember(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 long count)

已过时。

Get one or multiple random members from a set.

指定者:

srandmember 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

count - the count.

返回:

Long count of members of the resulting set.

srem

public reactor.core.publisher.Mono<Long> srem(String key,
 String... members)

Remove one or more members from a set.

指定者:

srem 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

members - the member type: value.

返回:

Long integer-reply the number of members that were removed from the set, not including non existing members.

sunion

public reactor.core.publisher.Flux<String> sunion(String... keys)

Add multiple sets.

指定者:

sunion 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

keys - the key.

返回:

V array-reply list with members of the resulting set.

sunion

@Deprecated
public reactor.core.publisher.Mono<Long> sunion(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String... keys)

已过时。

Add multiple sets.

指定者:

sunion 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

keys - the keys.

返回:

Long count of members of the resulting set.

sunionstore

public reactor.core.publisher.Mono<Long> sunionstore(String destination,
 String... keys)

Add multiple sets and store the resulting set in a key.

指定者:

sunionstore 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

destination - the destination type: key.

keys - the key.

返回:

Long integer-reply the number of elements in the resulting set.

sscan

public reactor.core.publisher.Mono<io.lettuce.core.ValueScanCursor<String>> sscan(String key)

Incrementally iterate Set elements.

指定者:

sscan 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

返回:

ValueScanCursor<V> scan cursor.

sscan

public reactor.core.publisher.Mono<io.lettuce.core.ValueScanCursor<String>> sscan(String key,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate Set elements.

指定者:

sscan 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

scanArgs - scan arguments.

返回:

ValueScanCursor<V> scan cursor.

sscan

public reactor.core.publisher.Mono<io.lettuce.core.ValueScanCursor<String>> sscan(String key,
 io.lettuce.core.ScanCursor scanCursor,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate Set elements.

指定者:

sscan 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

scanArgs - scan arguments.

返回:

ValueScanCursor<V> scan cursor.

sscan

public reactor.core.publisher.Mono<io.lettuce.core.ValueScanCursor<String>> sscan(String key,
 io.lettuce.core.ScanCursor scanCursor)

Incrementally iterate Set elements.

指定者:

sscan 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

返回:

ValueScanCursor<V> scan cursor.

sscan

@Deprecated
public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> sscan(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key)

已过时。

Incrementally iterate Set elements.

指定者:

sscan 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

返回:

StreamScanCursor scan cursor.

sscan

@Deprecated
public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> sscan(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.ScanArgs scanArgs)

已过时。

Incrementally iterate Set elements.

指定者:

sscan 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

scanArgs - scan arguments.

返回:

StreamScanCursor scan cursor.

sscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> sscan(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.ScanCursor scanCursor,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate Set elements.

指定者:

sscan 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

scanArgs - scan arguments.

返回:

StreamScanCursor scan cursor.

sscan

@Deprecated
public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> sscan(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.ScanCursor scanCursor)

已过时。

Incrementally iterate Set elements.

指定者:

sscan 在接口中 io.lettuce.core.api.reactive.RedisSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

返回:

StreamScanCursor scan cursor.

bzmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>> bzmpop(long l,
 io.lettuce.core.ZPopArgs zPopArgs,
 String... strings)

指定者:

bzmpop 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

bzmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<io.lettuce.core.ScoredValue<String>>>> bzmpop(long l,
 long l1,
 io.lettuce.core.ZPopArgs zPopArgs,
 String... strings)

指定者:

bzmpop 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

bzmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>> bzmpop(double v,
 io.lettuce.core.ZPopArgs zPopArgs,
 String... strings)

指定者:

bzmpop 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

bzmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<io.lettuce.core.ScoredValue<String>>>> bzmpop(double v,
 int i,
 io.lettuce.core.ZPopArgs zPopArgs,
 String... strings)

指定者:

bzmpop 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

bzpopmin

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>> bzpopmin(long timeout,
 String... keys)

Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.

指定者:

bzpopmin 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

timeout - the timeout in seconds.

keys - the keys.

返回:

KeyValue<K, ScoredValue<V>> multi-bulk containing the name of the key, the score and the popped member.

从以下版本开始:

5.1

bzpopmin

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>> bzpopmin(double v,
 String... strings)

指定者:

bzpopmin 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

bzpopmax

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>> bzpopmax(long timeout,
 String... keys)

Removes and returns a member with the highest scores in the sorted set stored at one of the keys.

指定者:

bzpopmax 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

timeout - the timeout in seconds.

keys - the keys.

返回:

KeyValue<K, ScoredValue<V>> multi-bulk containing the name of the key, the score and the popped member.

从以下版本开始:

5.1

bzpopmax

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>> bzpopmax(double v,
 String... strings)

指定者:

bzpopmax 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zadd

public reactor.core.publisher.Mono<Long> zadd(String key,
 double score,
 String member)

Add one or more members to a sorted set, or update its score if it already exists.

指定者:

zadd 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

score - the score.

member - the member.

返回:

Long integer-reply specifically:

The number of elements added to the sorted sets, not including elements already existing for which the score was updated.

zadd

public reactor.core.publisher.Mono<Long> zadd(String key,
 Object... scoresAndValues)

Add one or more members to a sorted set, or update its score if it already exists.

指定者:

zadd 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

scoresAndValues - the scoresAndValue tuples (score,value,score,value,...).

返回:

Long integer-reply specifically:

The number of elements added to the sorted sets, not including elements already existing for which the score was updated.

zadd

public reactor.core.publisher.Mono<Long> zadd(String key,
 io.lettuce.core.ScoredValue<String>... scoredValues)

Add one or more members to a sorted set, or update its score if it already exists.

指定者:

zadd 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

scoredValues - the scored values.

返回:

Long integer-reply specifically:

The number of elements added to the sorted sets, not including elements already existing for which the score was updated.

zadd

public reactor.core.publisher.Mono<Long> zadd(String key,
 io.lettuce.core.ZAddArgs zAddArgs,
 double score,
 String member)

Add one or more members to a sorted set, or update its score if it already exists.

指定者:

zadd 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

zAddArgs - arguments for zadd.

score - the score.

member - the member.

返回:

Long integer-reply specifically:

The number of elements added to the sorted sets, not including elements already existing for which the score was updated.

zadd

public reactor.core.publisher.Mono<Long> zadd(String key,
 io.lettuce.core.ZAddArgs zAddArgs,
 Object... scoresAndValues)

Add one or more members to a sorted set, or update its score if it already exists.

指定者:

zadd 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

zAddArgs - arguments for zadd.

scoresAndValues - the scoresAndValue tuples (score,value,score,value,...).

返回:

Long integer-reply specifically:

The number of elements added to the sorted sets, not including elements already existing for which the score was updated.

zadd

public reactor.core.publisher.Mono<Long> zadd(String key,
 io.lettuce.core.ZAddArgs zAddArgs,
 io.lettuce.core.ScoredValue<String>... scoredValues)

Add one or more members to a sorted set, or update its score if it already exists.

指定者:

zadd 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the ke.

zAddArgs - arguments for zadd.

scoredValues - the scored values.

返回:

Long integer-reply specifically:

The number of elements added to the sorted sets, not including elements already existing for which the score was updated.

zaddincr

public reactor.core.publisher.Mono<Double> zaddincr(String key,
 double score,
 String member)

Add one or more members to a sorted set, or update its score if it already exists applying the INCR option. ZADD acts like ZINCRBY.

指定者:

zaddincr 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

score - the score.

member - the member.

返回:

Long integer-reply specifically: The total number of elements changed.

zaddincr

public reactor.core.publisher.Mono<Double> zaddincr(String key,
 io.lettuce.core.ZAddArgs zAddArgs,
 double score,
 String member)

Add one or more members to a sorted set, or update its score if it already exists applying the INCR option. ZADD acts like ZINCRBY.

指定者:

zaddincr 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

zAddArgs - arguments for zadd.

score - the score.

member - the member.

返回:

Long integer-reply specifically: The total number of elements changed.

从以下版本开始:

4.3

zcard

public reactor.core.publisher.Mono<Long> zcard(String key)

Get the number of members in a sorted set.

指定者:

zcard 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

返回:

Long integer-reply the cardinality (number of elements) of the sorted set, or false if key does not exist.

zcount

@Deprecated
public reactor.core.publisher.Mono<Long> zcount(String key,
 double min,
 double max)

已过时。

Use RedisSortedSetReactiveCommands.zcount(Object, Range).

Count the members in a sorted set with scores within the given values.

指定者:

zcount 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

Long integer-reply the number of elements in the specified score range.

zcount

@Deprecated
public reactor.core.publisher.Mono<Long> zcount(String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zcount(Object, Range).

Count the members in a sorted set with scores within the given values.

指定者:

zcount 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

Long integer-reply the number of elements in the specified score range.

zcount

public reactor.core.publisher.Mono<Long> zcount(String key,
 io.lettuce.core.Range<? extends Number> range)

Count the members in a sorted set with scores within the given Range.

指定者:

zcount 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

Long integer-reply the number of elements in the specified score range.

从以下版本开始:

4.3

zdiff

public reactor.core.publisher.Flux<String> zdiff(String... strings)

指定者:

zdiff 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zdiffstore

public reactor.core.publisher.Mono<Long> zdiffstore(String s,
 String... strings)

指定者:

zdiffstore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zdiffWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zdiffWithScores(String... strings)

指定者:

zdiffWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zincrby

public reactor.core.publisher.Mono<Double> zincrby(String key,
 double amount,
 String member)

Increment the score of a member in a sorted set.

指定者:

zincrby 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

amount - the increment type: long.

member - the member type: value.

返回:

Double bulk-string-reply the new score of member (a double precision floating point number), represented as string.

zinter

public reactor.core.publisher.Flux<String> zinter(String... strings)

指定者:

zinter 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zinter

public reactor.core.publisher.Flux<String> zinter(io.lettuce.core.ZAggregateArgs zAggregateArgs,
 String... strings)

指定者:

zinter 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zintercard

public reactor.core.publisher.Mono<Long> zintercard(String... strings)

指定者:

zintercard 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zintercard

public reactor.core.publisher.Mono<Long> zintercard(long l,
 String... strings)

指定者:

zintercard 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zinterWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zinterWithScores(io.lettuce.core.ZAggregateArgs zAggregateArgs,
 String... strings)

指定者:

zinterWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zinterWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zinterWithScores(String... strings)

指定者:

zinterWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zinterstore

public reactor.core.publisher.Mono<Long> zinterstore(String destination,
 String... keys)

Intersect multiple sorted sets and store the resulting sorted set in a new key.

指定者:

zinterstore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

destination - the destination.

keys - the keys.

返回:

Long integer-reply the number of elements in the resulting sorted set at destination.

zinterstore

public reactor.core.publisher.Mono<Long> zinterstore(String destination,
 io.lettuce.core.ZStoreArgs storeArgs,
 String... keys)

Intersect multiple sorted sets and store the resulting sorted set in a new key.

指定者:

zinterstore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

destination - the destination.

storeArgs - the storeArgs.

keys - the keys.

返回:

Long integer-reply the number of elements in the resulting sorted set at destination.

zlexcount

@Deprecated
public reactor.core.publisher.Mono<Long> zlexcount(String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zlexcount(Object, Range).

Count the number of members in a sorted set between a given lexicographical range.

指定者:

zlexcount 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

Long integer-reply the number of elements in the specified score range.

zlexcount

public reactor.core.publisher.Mono<Long> zlexcount(String key,
 io.lettuce.core.Range<? extends String> range)

Count the number of members in a sorted set between a given lexicographical range.

指定者:

zlexcount 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

Long integer-reply the number of elements in the specified score range.

从以下版本开始:

4.3

zmscore

public reactor.core.publisher.Mono<List<Double>> zmscore(String s,
 String... strings)

指定者:

zmscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,io.lettuce.core.ScoredValue<String>>> zmpop(io.lettuce.core.ZPopArgs zPopArgs,
 String... strings)

指定者:

zmpop 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zmpop

public reactor.core.publisher.Mono<io.lettuce.core.KeyValue<String,List<io.lettuce.core.ScoredValue<String>>>> zmpop(int i,
 io.lettuce.core.ZPopArgs zPopArgs,
 String... strings)

指定者:

zmpop 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zpopmin

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<String>> zpopmin(String key)

Removes and returns up to count members with the lowest scores in the sorted set stored at key.

指定者:

zpopmin 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

返回:

ScoredValue<V> the removed element.

从以下版本开始:

5.1

zpopmin

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zpopmin(String key,
 long count)

Removes and returns up to count members with the lowest scores in the sorted set stored at key.

指定者:

zpopmin 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

count - the number of elements to return.

返回:

ScoredValue<V> array-reply list of popped scores and elements.

从以下版本开始:

5.1

zpopmax

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<String>> zpopmax(String key)

Removes and returns up to count members with the highest scores in the sorted set stored at key.

指定者:

zpopmax 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

返回:

ScoredValue<V> the removed element.

从以下版本开始:

5.1

zpopmax

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zpopmax(String key,
 long count)

Removes and returns up to count members with the highest scores in the sorted set stored at key.

指定者:

zpopmax 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

count - the number of elements to return.

返回:

ScoredValue<V> array-reply list of popped scores and elements.

从以下版本开始:

5.1

zrandmember

public reactor.core.publisher.Mono<String> zrandmember(String s)

指定者:

zrandmember 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrandmember

public reactor.core.publisher.Flux<String> zrandmember(String s,
 long l)

指定者:

zrandmember 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrandmemberWithScores

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<String>> zrandmemberWithScores(String s)

指定者:

zrandmemberWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrandmemberWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrandmemberWithScores(String s,
 long l)

指定者:

zrandmemberWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrange

public reactor.core.publisher.Flux<String> zrange(String key,
 long start,
 long stop)

Return a range of members in a sorted set, by index.

指定者:

zrange 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

start - the start.

stop - the stop.

返回:

V array-reply list of elements in the specified range.

zrange

@Deprecated
public reactor.core.publisher.Mono<Long> zrange(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 long start,
 long stop)

已过时。

Return a range of members in a sorted set, by index.

指定者:

zrange 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

start - the start.

stop - the stop.

返回:

Long count of elements in the specified range.

zrangeWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrangeWithScores(String key,
 long start,
 long stop)

Return a range of members with scores in a sorted set, by index.

指定者:

zrangeWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

start - the start.

stop - the stop.

返回:

V array-reply list of elements in the specified range.

zrangeWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrangeWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 long start,
 long stop)

已过时。

Stream over a range of members with scores in a sorted set, by index.

指定者:

zrangeWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

start - the start.

stop - the stop.

返回:

Long count of elements in the specified range.

zrangebylex

@Deprecated
public reactor.core.publisher.Flux<String> zrangebylex(String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebylex(Object, Range).

Return a range of members in a sorted set, by lexicographical range.

指定者:

zrangebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

V array-reply list of elements in the specified range.

zrangebylex

public reactor.core.publisher.Flux<String> zrangebylex(String key,
 io.lettuce.core.Range<? extends String> range)

Return a range of members in a sorted set, by lexicographical range.

指定者:

zrangebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

V array-reply list of elements in the specified range.

从以下版本开始:

4.3

zrangebylex

@Deprecated
public reactor.core.publisher.Flux<String> zrangebylex(String key,
 String min,
 String max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebylex(Object, Range).

Return a range of members in a sorted set, by lexicographical range.

指定者:

zrangebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

V array-reply list of elements in the specified range.

zrangebylex

public reactor.core.publisher.Flux<String> zrangebylex(String key,
 io.lettuce.core.Range<? extends String> range,
 io.lettuce.core.Limit limit)

Return a range of members in a sorted set, by lexicographical range.

指定者:

zrangebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

limit - the limit.

返回:

V array-reply list of elements in the specified range.

从以下版本开始:

4.3

zrangebyscore

@Deprecated
public reactor.core.publisher.Flux<String> zrangebyscore(String key,
 double min,
 double max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscore(Object, Range).

Return a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

V array-reply list of elements in the specified score range.

zrangebyscore

@Deprecated
public reactor.core.publisher.Flux<String> zrangebyscore(String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscore(Object, Range).

Return a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

V array-reply list of elements in the specified score range.

zrangebyscore

public reactor.core.publisher.Flux<String> zrangebyscore(String key,
 io.lettuce.core.Range<? extends Number> range)

Return a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

V array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrangebyscore

@Deprecated
public reactor.core.publisher.Flux<String> zrangebyscore(String key,
 double min,
 double max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscore(Object, Range, Limit).

Return a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

V array-reply list of elements in the specified score range.

zrangebyscore

@Deprecated
public reactor.core.publisher.Flux<String> zrangebyscore(String key,
 String min,
 String max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscore(Object, Range, Limit).

Return a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

V array-reply list of elements in the specified score range.

zrangebyscore

public reactor.core.publisher.Flux<String> zrangebyscore(String key,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

Return a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

limit - the limit.

返回:

V array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 double min,
 double max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscore(ValueStreamingChannel, Object, Range).

Stream over a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

min - min score.

max - max score.

返回:

Long count of elements in the specified score range.

zrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscore(ValueStreamingChannel, Object, Range).

Stream over a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

min - min score.

max - max score.

返回:

Long count of elements in the specified score range.

zrangebyscore

public reactor.core.publisher.Mono<Long> zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.Range<? extends Number> range)

Stream over a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

range - the range.

返回:

Long count of elements in the specified score range.

从以下版本开始:

4.3

zrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 double min,
 double max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscore(ValueStreamingChannel, Object, Range, Limit limit).

Stream over range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

Long count of elements in the specified score range.

zrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 String min,
 String max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscore(ValueStreamingChannel, Object, Range, Limit limit).

Stream over a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

Long count of elements in the specified score range.

zrangebyscore

public reactor.core.publisher.Mono<Long> zrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

Stream over a range of members in a sorted set, by score.

指定者:

zrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

range - the range.

limit - the limit.

返回:

Long count of elements in the specified score range.

从以下版本开始:

4.3

zrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrangebyscoreWithScores(String key,
 double min,
 double max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(Object, Range).

Return a range of members with score in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

zrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrangebyscoreWithScores(String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(Object, Range).

Return a range of members with score in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

zrangebyscoreWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrangebyscoreWithScores(String key,
 io.lettuce.core.Range<? extends Number> range)

Return a range of members with score in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrangebyscoreWithScores(String key,
 double min,
 double max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(Object, Range, Limit limit).

Return a range of members with score in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

zrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrangebyscoreWithScores(String key,
 String min,
 String max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(Object, Range, Limit).

Return a range of members with score in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

zrangebyscoreWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrangebyscoreWithScores(String key,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

Return a range of members with score in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

limit - the limit.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 double min,
 double max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range).

Stream over a range of members with scores in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

min - min score.

max - max score.

返回:

Long count of elements in the specified score range.

zrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range).

Stream over a range of members with scores in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

min - min score.

max - max score.

返回:

Long count of elements in the specified score range.

zrangebyscoreWithScores

public reactor.core.publisher.Mono<Long> zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.Range<? extends Number> range)

Stream over a range of members with scores in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

range - the range.

返回:

Long count of elements in the specified score range.

从以下版本开始:

4.3

zrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 double min,
 double max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range, Limit limit).

Stream over a range of members with scores in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

Long count of elements in the specified score range.

zrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 String min,
 String max,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range, Limit limit).

Stream over a range of members with scores in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

min - min score.

max - max score.

offset - the offset.

count - the count.

返回:

Long count of elements in the specified score range.

zrangebyscoreWithScores

public reactor.core.publisher.Mono<Long> zrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

Stream over a range of members with scores in a sorted set, by score.

指定者:

zrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

range - the range.

limit - the limit.

返回:

Long count of elements in the specified score range.

从以下版本开始:

4.3

zrangestore

public reactor.core.publisher.Mono<Long> zrangestore(String s,
 String k1,
 io.lettuce.core.Range<Long> range)

指定者:

zrangestore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrangestorebylex

public reactor.core.publisher.Mono<Long> zrangestorebylex(String s,
 String k1,
 io.lettuce.core.Range<? extends String> range,
 io.lettuce.core.Limit limit)

指定者:

zrangestorebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrangestorebyscore

public reactor.core.publisher.Mono<Long> zrangestorebyscore(String s,
 String k1,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

指定者:

zrangestorebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrank

public reactor.core.publisher.Mono<Long> zrank(String key,
 String member)

Determine the index of a member in a sorted set.

指定者:

zrank 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

member - the member type: value.

返回:

Long integer-reply the rank of member. If member does not exist in the sorted set or key does not exist,.

zrankWithScore

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<Long>> zrankWithScore(String s,
 String s2)

指定者:

zrankWithScore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrem

public reactor.core.publisher.Mono<Long> zrem(String key,
 String... members)

Remove one or more members from a sorted set.

指定者:

zrem 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

members - the member type: value.

返回:

Long integer-reply specifically:

The number of members removed from the sorted set, not including non existing members.

zremrangebylex

@Deprecated
public reactor.core.publisher.Mono<Long> zremrangebylex(String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zremrangebylex(Object, Range).

Remove all members in a sorted set between the given lexicographical range.

指定者:

zremrangebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

Long integer-reply the number of elements removed.

zremrangebylex

public reactor.core.publisher.Mono<Long> zremrangebylex(String key,
 io.lettuce.core.Range<? extends String> range)

Remove all members in a sorted set between the given lexicographical range.

指定者:

zremrangebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

Long integer-reply the number of elements removed.

从以下版本开始:

4.3

zremrangebyrank

public reactor.core.publisher.Mono<Long> zremrangebyrank(String key,
 long start,
 long stop)

Remove all members in a sorted set within the given indexes.

指定者:

zremrangebyrank 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

start - the start type: long.

stop - the stop type: long.

返回:

Long integer-reply the number of elements removed.

zremrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zremrangebyscore(String key,
 double min,
 double max)

已过时。

Use RedisSortedSetReactiveCommands.zremrangebyscore(Object, Range).

Remove all members in a sorted set within the given scores.

指定者:

zremrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

Long integer-reply the number of elements removed.

zremrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zremrangebyscore(String key,
 String min,
 String max)

已过时。

Use RedisSortedSetReactiveCommands.zremrangebyscore(Object, Range).

Remove all members in a sorted set within the given scores.

指定者:

zremrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

min - min score.

max - max score.

返回:

Long integer-reply the number of elements removed.

zremrangebyscore

public reactor.core.publisher.Mono<Long> zremrangebyscore(String key,
 io.lettuce.core.Range<? extends Number> range)

Remove all members in a sorted set within the given scores.

指定者:

zremrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

Long integer-reply the number of elements removed.

从以下版本开始:

4.3

zrevrange

public reactor.core.publisher.Flux<String> zrevrange(String key,
 long start,
 long stop)

Return a range of members in a sorted set, by index, with scores ordered from high to low.

指定者:

zrevrange 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

start - the start.

stop - the stop.

返回:

V array-reply list of elements in the specified range.

zrevrange

public reactor.core.publisher.Mono<Long> zrevrange(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 long start,
 long stop)

Stream over a range of members in a sorted set, by index, with scores ordered from high to low.

指定者:

zrevrange 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

start - the start.

stop - the stop.

返回:

Long count of elements in the specified range.

zrevrangeWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrevrangeWithScores(String key,
 long start,
 long stop)

Return a range of members with scores in a sorted set, by index, with scores ordered from high to low.

指定者:

zrevrangeWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

start - the start.

stop - the stop.

返回:

V array-reply list of elements in the specified range.

zrevrangeWithScores

public reactor.core.publisher.Mono<Long> zrevrangeWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 long start,
 long stop)

Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.

指定者:

zrevrangeWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

start - the start.

stop - the stop.

返回:

Long count of elements in the specified range.

zrevrangebylex

public reactor.core.publisher.Flux<String> zrevrangebylex(String key,
 io.lettuce.core.Range<? extends String> range)

Return a range of members in a sorted set, by lexicographical range ordered from high to low.

指定者:

zrevrangebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

V array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrevrangebylex

public reactor.core.publisher.Flux<String> zrevrangebylex(String key,
 io.lettuce.core.Range<? extends String> range,
 io.lettuce.core.Limit limit)

Return a range of members in a sorted set, by lexicographical range ordered from high to low.

指定者:

zrevrangebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

limit - the limit.

返回:

V array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrevrangebyscore

@Deprecated
public reactor.core.publisher.Flux<String> zrevrangebyscore(String key,
 double max,
 double min)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range).

Return a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

max - max score.

min - min score.

返回:

V array-reply list of elements in the specified score range.

zrevrangebyscore

@Deprecated
public reactor.core.publisher.Flux<String> zrevrangebyscore(String key,
 String max,
 String min)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range).

Return a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

max - max score.

min - min score.

返回:

V array-reply list of elements in the specified score range.

zrevrangebyscore

public reactor.core.publisher.Flux<String> zrevrangebyscore(String key,
 io.lettuce.core.Range<? extends Number> range)

Return a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

V array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrevrangebyscore

@Deprecated
public reactor.core.publisher.Flux<String> zrevrangebyscore(String key,
 double max,
 double min,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range, Limit).

Return a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

max - max score.

min - min score.

offset - the withscores.

count - the null.

返回:

V array-reply list of elements in the specified score range.

zrevrangebyscore

@Deprecated
public reactor.core.publisher.Flux<String> zrevrangebyscore(String key,
 String max,
 String min,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range, Limit).

Return a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

max - max score.

min - min score.

offset - the offset.

count - the count.

返回:

V array-reply list of elements in the specified score range.

zrevrangebyscore

public reactor.core.publisher.Flux<String> zrevrangebyscore(String key,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

Return a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

limit - the limit.

返回:

V array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrevrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 double max,
 double min)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range).

Stream over a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

max - max score.

min - min score.

返回:

Long count of elements in the specified range.

zrevrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 String max,
 String min)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscore(Object, Range).

Stream over a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

max - max score.

min - min score.

返回:

Long count of elements in the specified range.

zrevrangebyscore

public reactor.core.publisher.Mono<Long> zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.Range<? extends Number> range)

Stream over a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

range - the range.

返回:

Long count of elements in the specified range.

从以下版本开始:

4.3

zrevrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 double max,
 double min,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range, Limit).

Stream over a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

max - max score.

min - min score.

offset - the offset.

count - the count.

返回:

Long count of elements in the specified range.

zrevrangebyscore

@Deprecated
public reactor.core.publisher.Mono<Long> zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 String max,
 String min,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range, Limit).

Stream over a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

max - max score.

min - min score.

offset - the offset.

count - the count.

返回:

Long count of elements in the specified range.

zrevrangebyscore

public reactor.core.publisher.Mono<Long> zrevrangebyscore(io.lettuce.core.output.ValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

Stream over a range of members in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every value.

key - the key.

range - the range.

limit - the limit.

返回:

Long count of elements in the specified range.

从以下版本开始:

4.3

zrevrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrevrangebyscoreWithScores(String key,
 double max,
 double min)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range).

Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

max - max score.

min - min score.

返回:

V array-reply list of elements in the specified score range.

zrevrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrevrangebyscoreWithScores(String key,
 String max,
 String min)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range).

Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

max - max score.

min - min score.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

zrevrangebyscoreWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrevrangebyscoreWithScores(String key,
 io.lettuce.core.Range<? extends Number> range)

Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrevrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrevrangebyscoreWithScores(String key,
 double max,
 double min,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range, Limit).

Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

max - max score.

min - min score.

offset - the offset.

count - the count.

返回:

ScoredValue<V> array-reply list of elements in the specified score range.

zrevrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrevrangebyscoreWithScores(String key,
 String max,
 String min,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(Object, Range, Limit).

Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

max - max score.

min - min score.

offset - the offset.

count - the count.

返回:

V array-reply list of elements in the specified score range.

zrevrangebyscoreWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zrevrangebyscoreWithScores(String key,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

range - the range.

limit - limit.

返回:

V array-reply list of elements in the specified score range.

从以下版本开始:

4.3

zrevrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 double max,
 double min)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range).

Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

max - max score.

min - min score.

返回:

Long count of elements in the specified range.

zrevrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 String max,
 String min)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range).

Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

max - max score.

min - min score.

返回:

Long count of elements in the specified range.

zrevrangebyscoreWithScores

public reactor.core.publisher.Mono<Long> zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.Range<? extends Number> range)

Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

range - the range.

返回:

Long count of elements in the specified range.

zrevrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 double max,
 double min,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range, Limit).

Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

max - max score.

min - min score.

offset - the offset.

count - the count.

返回:

Long count of elements in the specified range.

zrevrangebyscoreWithScores

@Deprecated
public reactor.core.publisher.Mono<Long> zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 String max,
 String min,
 long offset,
 long count)

已过时。

Use RedisSortedSetReactiveCommands.zrevrangebyscoreWithScores(ScoredValueStreamingChannel, Object, Range, Limit).

Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

max - max score.

min - min score.

offset - the offset.

count - the count.

返回:

Long count of elements in the specified range.

zrevrangebyscoreWithScores

public reactor.core.publisher.Mono<Long> zrevrangebyscoreWithScores(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.

指定者:

zrevrangebyscoreWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

range - the range.

limit - the limit.

返回:

Long count of elements in the specified range.

从以下版本开始:

4.3

zrevrangestore

public reactor.core.publisher.Mono<Long> zrevrangestore(String s,
 String k1,
 io.lettuce.core.Range<Long> range)

指定者:

zrevrangestore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrevrangestorebylex

public reactor.core.publisher.Mono<Long> zrevrangestorebylex(String s,
 String k1,
 io.lettuce.core.Range<? extends String> range,
 io.lettuce.core.Limit limit)

指定者:

zrevrangestorebylex 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrevrangestorebyscore

public reactor.core.publisher.Mono<Long> zrevrangestorebyscore(String s,
 String k1,
 io.lettuce.core.Range<? extends Number> range,
 io.lettuce.core.Limit limit)

指定者:

zrevrangestorebyscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zrevrank

public reactor.core.publisher.Mono<Long> zrevrank(String key,
 String member)

Determine the index of a member in a sorted set, with scores ordered from high to low.

指定者:

zrevrank 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

member - the member type: value.

返回:

Long integer-reply the rank of member. If member does not exist in the sorted set or key does not exist,.

zrevrankWithScore

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValue<Long>> zrevrankWithScore(String s,
 String s2)

指定者:

zrevrankWithScore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zscan

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValueScanCursor<String>> zscan(String key)

Incrementally iterate sorted sets elements and associated scores.

指定者:

zscan 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

返回:

ScoredValueScanCursor<V> scan cursor.

zscan

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValueScanCursor<String>> zscan(String key,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate sorted sets elements and associated scores.

指定者:

zscan 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

scanArgs - scan arguments.

返回:

ScoredValueScanCursor<V> scan cursor.

zscan

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValueScanCursor<String>> zscan(String key,
 io.lettuce.core.ScanCursor scanCursor,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate sorted sets elements and associated scores.

指定者:

zscan 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

scanArgs - scan arguments.

返回:

ScoredValueScanCursor<V> scan cursor.

zscan

public reactor.core.publisher.Mono<io.lettuce.core.ScoredValueScanCursor<String>> zscan(String key,
 io.lettuce.core.ScanCursor scanCursor)

Incrementally iterate sorted sets elements and associated scores.

指定者:

zscan 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

返回:

ScoredValueScanCursor<V> scan cursor.

zscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> zscan(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key)

Incrementally iterate sorted sets elements and associated scores.

指定者:

zscan 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

返回:

StreamScanCursor scan cursor.

zscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> zscan(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate sorted sets elements and associated scores.

指定者:

zscan 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

scanArgs - scan arguments.

返回:

StreamScanCursor scan cursor.

zscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> zscan(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.ScanCursor scanCursor,
 io.lettuce.core.ScanArgs scanArgs)

Incrementally iterate sorted sets elements and associated scores.

指定者:

zscan 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

scanArgs - scan arguments.

返回:

StreamScanCursor scan cursor.

zscan

public reactor.core.publisher.Mono<io.lettuce.core.StreamScanCursor> zscan(io.lettuce.core.output.ScoredValueStreamingChannel<String> channel,
 String key,
 io.lettuce.core.ScanCursor scanCursor)

Incrementally iterate sorted sets elements and associated scores.

指定者:

zscan 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

channel - streaming channel that receives a call for every scored value.

key - the key.

scanCursor - cursor to resume from a previous scan, must not be null.

返回:

StreamScanCursor scan cursor.

zscore

public reactor.core.publisher.Mono<Double> zscore(String key,
 String member)

Get the score associated with the given member in a sorted set.

指定者:

zscore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

key - the key.

member - the member type: value.

返回:

Double bulk-string-reply the score of member (a double precision floating point number), represented as string.

zunion

public reactor.core.publisher.Flux<String> zunion(String... strings)

指定者:

zunion 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zunion

public reactor.core.publisher.Flux<String> zunion(io.lettuce.core.ZAggregateArgs zAggregateArgs,
 String... strings)

指定者:

zunion 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zunionWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zunionWithScores(io.lettuce.core.ZAggregateArgs zAggregateArgs,
 String... strings)

指定者:

zunionWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zunionWithScores

public reactor.core.publisher.Flux<io.lettuce.core.ScoredValue<String>> zunionWithScores(String... strings)

指定者:

zunionWithScores 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

zunionstore

public reactor.core.publisher.Mono<Long> zunionstore(String destination,
 String... keys)

Add multiple sorted sets and store the resulting sorted set in a new key.

指定者:

zunionstore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

destination - destination key.

keys - source keys.

返回:

Long integer-reply the number of elements in the resulting sorted set at destination.

zunionstore

public reactor.core.publisher.Mono<Long> zunionstore(String destination,
 io.lettuce.core.ZStoreArgs storeArgs,
 String... keys)

Add multiple sorted sets and store the resulting sorted set in a new key.

指定者:

zunionstore 在接口中 io.lettuce.core.api.reactive.RedisSortedSetReactiveCommands<String,String>

参数:

destination - the destination.

storeArgs - the storeArgs.

keys - the keys.

返回:

Long integer-reply the number of elements in the resulting sorted set at destination.

xack

public reactor.core.publisher.Mono<Long> xack(String key,
 String group,
 String... messageIds)

Acknowledge one or more messages as processed.

指定者:

xack 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

group - name of the consumer group.

messageIds - message Id's to acknowledge.

返回:

simple-reply the lenght of acknowledged messages.

xadd

public reactor.core.publisher.Mono<String> xadd(String key,
 Map<String,String> body)

Append a message to the stream key.

指定者:

xadd 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

body - message body.

返回:

simple-reply the message Id.

xadd

public reactor.core.publisher.Mono<String> xadd(String key,
 io.lettuce.core.XAddArgs args,
 Map<String,String> body)

Append a message to the stream key.

指定者:

xadd 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

args -

body - message body.

返回:

simple-reply the message Id.

xadd

public reactor.core.publisher.Mono<String> xadd(String key,
 Object... keysAndValues)

Append a message to the stream key.

指定者:

xadd 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

keysAndValues - message body.

返回:

simple-reply the message Id.

xadd

public reactor.core.publisher.Mono<String> xadd(String key,
 io.lettuce.core.XAddArgs args,
 Object... keysAndValues)

Append a message to the stream key.

指定者:

xadd 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

args -

keysAndValues - message body.

返回:

simple-reply the message Id.

xautoclaim

public reactor.core.publisher.Mono<io.lettuce.core.models.stream.ClaimedMessages<String,String>> xautoclaim(String s,
 io.lettuce.core.XAutoClaimArgs<String> xAutoClaimArgs)

指定者:

xautoclaim 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

xclaim

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xclaim(String key,
 io.lettuce.core.Consumer<String> consumer,
 long minIdleTime,
 String... messageIds)

Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.

指定者:

xclaim 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

consumer - consumer identified by group name and consumer key.

minIdleTime -

messageIds - message Id's to claim.

返回:

simple-reply the StreamMessage.

xclaim

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xclaim(String key,
 io.lettuce.core.Consumer<String> consumer,
 io.lettuce.core.XClaimArgs args,
 String... messageIds)

Gets ownership of one or multiple messages in the Pending Entries List of a given stream consumer group.

Note that setting the JUSTID flag (calling this method with XClaimArgs.justid()) suppresses the message bode and StreamMessage.getBody() is null.

指定者:

xclaim 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

consumer - consumer identified by group name and consumer key.

args -

messageIds - message Id's to claim.

返回:

simple-reply the StreamMessage.

xdel

public reactor.core.publisher.Mono<Long> xdel(String key,
 String... messageIds)

Removes the specified entries from the stream. Returns the number of items deleted, that may be different from the number of IDs passed in case certain IDs do not exist.

指定者:

xdel 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

messageIds - stream message Id's.

返回:

simple-reply number of removed entries.

xgroupCreate

public reactor.core.publisher.Mono<String> xgroupCreate(io.lettuce.core.XReadArgs.StreamOffset<String> streamOffset,
 String group)

Create a consumer group.

指定者:

xgroupCreate 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

streamOffset - name of the stream containing the offset to set.

group - name of the consumer group.

返回:

simple-reply true if successful.

xgroupCreate

public reactor.core.publisher.Mono<String> xgroupCreate(io.lettuce.core.XReadArgs.StreamOffset<String> streamOffset,
 String group,
 io.lettuce.core.XGroupCreateArgs args)

Create a consumer group.

指定者:

xgroupCreate 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

streamOffset - name of the stream containing the offset to set.

group - name of the consumer group.

args -

返回:

simple-reply true if successful.

从以下版本开始:

5.2

xgroupCreateconsumer

public reactor.core.publisher.Mono<Boolean> xgroupCreateconsumer(String s,
 io.lettuce.core.Consumer<String> consumer)

指定者:

xgroupCreateconsumer 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

xgroupDelconsumer

public reactor.core.publisher.Mono<Long> xgroupDelconsumer(String s,
 io.lettuce.core.Consumer<String> consumer)

指定者:

xgroupDelconsumer 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

xgroupDestroy

public reactor.core.publisher.Mono<Boolean> xgroupDestroy(String key,
 String group)

Destroy a consumer group.

指定者:

xgroupDestroy 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

group - name of the consumer group.

返回:

simple-reply true if successful.

xgroupSetid

public reactor.core.publisher.Mono<String> xgroupSetid(io.lettuce.core.XReadArgs.StreamOffset<String> streamOffset,
 String group)

Set the current group id.

指定者:

xgroupSetid 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

streamOffset - name of the stream containing the offset to set.

group - name of the consumer group.

返回:

simple-reply OK.

xinfoStream

public reactor.core.publisher.Flux<Object> xinfoStream(String key)

Retrieve information about the stream at key.

指定者:

xinfoStream 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

返回:

Object array-reply.

从以下版本开始:

5.2

xinfoGroups

public reactor.core.publisher.Flux<Object> xinfoGroups(String key)

Retrieve information about the stream consumer groups at key.

指定者:

xinfoGroups 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

返回:

Object array-reply.

从以下版本开始:

5.2

xinfoConsumers

public reactor.core.publisher.Flux<Object> xinfoConsumers(String key,
 String group)

Retrieve information about consumer groups of group group and stream at key.

指定者:

xinfoConsumers 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

group - name of the consumer group.

返回:

Object array-reply.

从以下版本开始:

5.2

xlen

public reactor.core.publisher.Mono<Long> xlen(String key)

Get the length of a steam.

指定者:

xlen 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

返回:

simple-reply the lenght of the stream.

xpending

public reactor.core.publisher.Mono<io.lettuce.core.models.stream.PendingMessages> xpending(String s,
 String k1)

指定者:

xpending 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

xpending

public reactor.core.publisher.Flux<io.lettuce.core.models.stream.PendingMessage> xpending(String s,
 String k1,
 io.lettuce.core.Range<String> range,
 io.lettuce.core.Limit limit)

指定者:

xpending 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

xpending

public reactor.core.publisher.Flux<io.lettuce.core.models.stream.PendingMessage> xpending(String s,
 io.lettuce.core.Consumer<String> consumer,
 io.lettuce.core.Range<String> range,
 io.lettuce.core.Limit limit)

指定者:

xpending 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

xpending

public reactor.core.publisher.Flux<io.lettuce.core.models.stream.PendingMessage> xpending(String s,
 io.lettuce.core.XPendingArgs<String> xPendingArgs)

指定者:

xpending 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

xrange

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xrange(String key,
 io.lettuce.core.Range<String> range)

Read messages from a stream within a specific Range.

指定者:

xrange 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

range - must not be null.

返回:

StreamMessage array-reply list with members of the resulting stream.

xrange

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xrange(String key,
 io.lettuce.core.Range<String> range,
 io.lettuce.core.Limit limit)

Read messages from a stream within a specific Range applying a Limit.

指定者:

xrange 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

range - must not be null.

limit - must not be null.

返回:

StreamMessage array-reply list with members of the resulting stream.

xread

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xread(io.lettuce.core.XReadArgs.StreamOffset<String>... streams)

Read messages from one or more StreamOffsets.

指定者:

xread 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

streams - the streams to read from.

返回:

StreamMessage array-reply list with members of the resulting stream.

xread

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xread(io.lettuce.core.XReadArgs args,
 io.lettuce.core.XReadArgs.StreamOffset<String>... streams)

Read messages from one or more StreamOffsets.

指定者:

xread 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

args - read arguments.

streams - the streams to read from.

返回:

StreamMessage array-reply list with members of the resulting stream.

xreadgroup

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xreadgroup(io.lettuce.core.Consumer<String> consumer,
 io.lettuce.core.XReadArgs.StreamOffset<String>... streams)

Read messages from one or more StreamOffsets using a consumer group.

指定者:

xreadgroup 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

consumer - consumer/group.

streams - the streams to read from.

返回:

StreamMessage array-reply list with members of the resulting stream.

xreadgroup

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xreadgroup(io.lettuce.core.Consumer<String> consumer,
 io.lettuce.core.XReadArgs args,
 io.lettuce.core.XReadArgs.StreamOffset<String>... streams)

Read messages from one or more StreamOffsets using a consumer group.

指定者:

xreadgroup 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

consumer - consumer/group.

args - read arguments.

streams - the streams to read from.

返回:

StreamMessage array-reply list with members of the resulting stream.

xrevrange

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xrevrange(String key,
 io.lettuce.core.Range<String> range)

Read messages from a stream within a specific Range in reverse order.

指定者:

xrevrange 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

range - must not be null.

返回:

StreamMessage array-reply list with members of the resulting stream.

xrevrange

public reactor.core.publisher.Flux<io.lettuce.core.StreamMessage<String,String>> xrevrange(String key,
 io.lettuce.core.Range<String> range,
 io.lettuce.core.Limit limit)

Read messages from a stream within a specific Range applying a Limit in reverse order.

指定者:

xrevrange 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

range - must not be null.

limit - must not be null.

返回:

StreamMessage array-reply list with members of the resulting stream.

xtrim

public reactor.core.publisher.Mono<Long> xtrim(String key,
 long count)

Trims the stream to count elements.

指定者:

xtrim 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

count - length of the stream.

返回:

simple-reply number of removed entries.

xtrim

public reactor.core.publisher.Mono<Long> xtrim(String key,
 boolean approximateTrimming,
 long count)

Trims the stream to count elements.

指定者:

xtrim 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

参数:

key - the stream key.

approximateTrimming - true to trim approximately using the ~ flag.

count - length of the stream.

返回:

simple-reply number of removed entries.

xtrim

public reactor.core.publisher.Mono<Long> xtrim(String s,
 io.lettuce.core.XTrimArgs xTrimArgs)

指定者:

xtrim 在接口中 io.lettuce.core.api.reactive.RedisStreamReactiveCommands<String,String>

aclCat

public reactor.core.publisher.Mono<Set<io.lettuce.core.AclCategory>> aclCat()

指定者:

aclCat 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclCat

public reactor.core.publisher.Mono<Set<io.lettuce.core.protocol.CommandType>> aclCat(io.lettuce.core.AclCategory aclCategory)

指定者:

aclCat 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclDeluser

public reactor.core.publisher.Mono<Long> aclDeluser(String... strings)

指定者:

aclDeluser 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclDryRun

public reactor.core.publisher.Mono<String> aclDryRun(String s,
 String s1,
 String... strings)

指定者:

aclDryRun 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclDryRun

public reactor.core.publisher.Mono<String> aclDryRun(String s,
 io.lettuce.core.protocol.RedisCommand<String,String,?> redisCommand)

指定者:

aclDryRun 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclGenpass

public reactor.core.publisher.Mono<String> aclGenpass()

指定者:

aclGenpass 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclGenpass

public reactor.core.publisher.Mono<String> aclGenpass(int i)

指定者:

aclGenpass 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclGetuser

public reactor.core.publisher.Mono<List<Object>> aclGetuser(String s)

指定者:

aclGetuser 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclList

public reactor.core.publisher.Flux<String> aclList()

指定者:

aclList 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclLoad

public reactor.core.publisher.Mono<String> aclLoad()

指定者:

aclLoad 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclLog

public reactor.core.publisher.Flux<Map<String,Object>> aclLog()

指定者:

aclLog 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclLog

public reactor.core.publisher.Flux<Map<String,Object>> aclLog(int i)

指定者:

aclLog 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclLogReset

public reactor.core.publisher.Mono<String> aclLogReset()

指定者:

aclLogReset 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclSave

public reactor.core.publisher.Mono<String> aclSave()

指定者:

aclSave 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclSetuser

public reactor.core.publisher.Mono<String> aclSetuser(String s,
 io.lettuce.core.AclSetuserArgs aclSetuserArgs)

指定者:

aclSetuser 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclUsers

public reactor.core.publisher.Flux<String> aclUsers()

指定者:

aclUsers 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

aclWhoami

public reactor.core.publisher.Mono<String> aclWhoami()

指定者:

aclWhoami 在接口中 io.lettuce.core.api.reactive.RedisAclReactiveCommands<String,String>

fcall

public <T> reactor.core.publisher.Flux<T> fcall(String s,
 io.lettuce.core.ScriptOutputType scriptOutputType,
 String... strings)

指定者:

fcall 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

fcall

public <T> reactor.core.publisher.Flux<T> fcall(String s,
 io.lettuce.core.ScriptOutputType scriptOutputType,
 String[] strings,
 String... strings2)

指定者:

fcall 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

fcallReadOnly

public <T> reactor.core.publisher.Flux<T> fcallReadOnly(String s,
 io.lettuce.core.ScriptOutputType scriptOutputType,
 String... strings)

指定者:

fcallReadOnly 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

fcallReadOnly

public <T> reactor.core.publisher.Flux<T> fcallReadOnly(String s,
 io.lettuce.core.ScriptOutputType scriptOutputType,
 String[] strings,
 String... strings2)

指定者:

fcallReadOnly 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionLoad

public reactor.core.publisher.Mono<String> functionLoad(String s)

指定者:

functionLoad 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionLoad

public reactor.core.publisher.Mono<String> functionLoad(String s,
 boolean b)

指定者:

functionLoad 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionDump

public reactor.core.publisher.Mono<byte[]> functionDump()

指定者:

functionDump 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionRestore

public reactor.core.publisher.Mono<String> functionRestore(byte[] bytes)

指定者:

functionRestore 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionRestore

public reactor.core.publisher.Mono<String> functionRestore(byte[] bytes,
 io.lettuce.core.FunctionRestoreMode functionRestoreMode)

指定者:

functionRestore 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionFlush

public reactor.core.publisher.Mono<String> functionFlush(io.lettuce.core.FlushMode flushMode)

指定者:

functionFlush 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionKill

public reactor.core.publisher.Mono<String> functionKill()

指定者:

functionKill 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionList

public reactor.core.publisher.Flux<Map<String,Object>> functionList()

指定者:

functionList 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>

functionList

public reactor.core.publisher.Flux<Map<String,Object>> functionList(String s)

指定者:

functionList 在接口中 io.lettuce.core.api.reactive.RedisFunctionReactiveCommands<String,String>