Class ValkeyAPI
java.lang.Object
io.vertx.rxjava3.redis.client.ValkeyAPI
- All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionA container for Access List Control commands.static ValkeyAPIstatic ValkeyAPIapi(RedisConnection connection) Appends a string to the value of a key.asking()Signals that a cluster client is following an -ASK redirect.Authenticates the connection.Asynchronously rewrites the append-only file to disk.Asynchronously saves the database(s) to disk.Counts the number of set bits (population counting) in a string.Performs arbitrary bitfield integer operations on strings.bitfieldRo(List<String> args) Performs arbitrary read-only bitfield integer operations on strings.Performs bitwise operations on multiple strings, and stores the result.Finds the first set (1) or clear (0) bit in a string.Pops an element from a list, pushes it to another list and returns it.Pops the first element from one of multiple lists.Removes and returns the first element in a list.Removes and returns the last element in a list.brpoplpush(String arg0, String arg1, String arg2) Pops an element from a list, pushes it to another list and returns it.Removes and returns a member by score from one or more sorted sets.Removes and returns the member with the highest score from one or more sorted sets.Removes and returns the member with the lowest score from one or more sorted sets.A container for client connection commands.voidclose()A container for Cluster commands.Returns detailed information about all commands.commandlog(List<String> args) A container for command log commands.A container for server configuration commands.Copies the value of a key to a new key.dbsize()Returns the number of keys in the database.A container for debugging commands.Decrements the integer value of a key by one.Decrements a number from the integer value of a key.Deletes one or more keys.Delete key if value matches string.discard()Discards a transaction.Returns a serialized representation of the value stored at a key.Returns the given string.booleanExecutes a server-side Lua script.Executes a read-only server-side Lua script.Executes a server-side Lua script by SHA1 digest.Executes a read-only server-side Lua script by SHA1 digest.exec()Executes all commands in a transaction.Determines whether one or more keys exist.Sets the expiration time of a key in seconds.Sets the expiration time of a key to a Unix timestamp.expiretime(String arg0) Returns the expiration time of a key as a Unix timestamp.Starts a coordinated failover from a server to one of its replicas.Invokes a function.Invokes a read-only function.Removes all keys from all databases.Remove all keys from the current database.A container for function commands.Adds one or more members to a geospatial index.Returns the distance between two members of a geospatial index.Returns members from a geospatial index as geohash strings.Returns the longitude and latitude of members from a geospatial index.Queries a geospatial index for members within a distance from a coordinate, optionally stores the result.georadiusbymember(List<String> args) Queries a geospatial index for members within a distance from a member, optionally stores the result.georadiusbymemberRo(List<String> args) Returns members from a geospatial index that are within a distance from a member.georadiusRo(List<String> args) Returns members from a geospatial index that are within a distance from a coordinate.Queries a geospatial index for members inside an area of a box, circle, or a polygon.geosearchstore(List<String> args) Queries a geospatial index for members inside an area of a box, a circle, or a polygon, optionally stores the result.Returns the string value of a key.Returns a bit value by offset.Returns the string value of a key after deleting the key.Returns the string value of a key after setting its expiration time.Returns a substring of the string stored at a key.Returns the previous string value of a key after setting it to a new value.inthashCode()Deletes one or more fields and their values from a hash.Handshakes with the server.Determines whether a field exists in a hash.Set expiry time on hash fields.Set expiry time on hash fields.hexpiretime(List<String> args) Returns Unix timestamps in seconds since the epoch at which the given key's field(s) will expire.Returns the value of a field in a hash.Returns all fields and values in a hash.Get the value of one or more fields of a given hash key, and optionally set their expiration time or time-to-live (TTL).Increments the integer value of a field in a hash by a number.hincrbyfloat(String arg0, String arg1, String arg2) Increments the floating point value of a field by a number.Returns all fields in a hash.Returns the number of fields in a hash.Returns the values of all fields in a hash.Sets the values of multiple fields.Remove the existing expiration on a hash key's field(s).Set expiry time on hash object.hpexpireat(List<String> args) Set expiration time on hash field.hpexpiretime(List<String> args) Returns the Unix timestamp in milliseconds since Unix epoch at which the given key's field(s) will expire.Returns the remaining time to live in milliseconds of a hash key's field(s) that have an associated expiration.hrandfield(List<String> args) Returns one or more random fields from a hash.Iterates over fields and values of a hash.Creates or modifies the value of a field in a hash.Set the value of one or more fields of a given hash key, and optionally set their expiration time.Sets the value of a field in a hash only when the field doesn't exist.Returns the length of the value of a field.Returns the remaining time to live (in seconds) of a hash key's field(s) that have an associated expiration.Returns all values in a hash.Increments the integer value of a key by one.Increments the integer value of a key by a number.incrbyfloat(String arg0, String arg1) Increment the floating point value of a key by a number.Returns information and statistics about the server.Returns all key names that match a pattern.lastsave()Returns the Unix timestamp of the last successful save to disk.A container for latency diagnostics commands.Finds the longest common substring.Returns an element from a list by its index.Inserts an element before or after another element in a list.Returns the length of a list.Returns an element after popping it from one list and pushing it to another.Returns multiple elements from a list after removing them.Displays computer art and the server version.Returns and removes one or more elements from the beginning of a list.Returns the index of matching elements in a list.Prepends one or more elements to a list.Prepends one or more elements to a list only when the list exists.Returns a range of elements from a list.Removes elements from a list.Sets the value of an element in a list by its index.Removes elements from both ends a list.A container for memory diagnostics commands.Atomically returns the string values of one or more keys.Atomically transfers a key from one instance to another.A container for module commands.monitor()Listens for all requests received by the server in real-time.Moves a key to another database.Atomically creates or modifies the string values of one or more keys.Atomically modifies the string values of one or more keys only when all keys don't exist.multi()Starts a transaction.static ValkeyAPInewInstance(ValkeyAPI arg) A container for object introspection commands.Removes the expiration time of a key.Sets the expiration time of a key in milliseconds.Sets the expiration time of a key to a Unix milliseconds timestamp.pexpiretime(String arg0) Returns the expiration time of a key as a Unix milliseconds timestamp.Adds elements to a HyperLogLog key.Returns the approximated cardinality of the set(s) observed by the HyperLogLog key(s).Internal commands for debugging HyperLogLog values.Merges one or more HyperLogLog values into a single key.An internal command for testing HyperLogLog values.Returns the server's liveliness response.Sets both string value and expiration time in milliseconds of a key.psubscribe(List<String> args) Listens for messages published to channels that match one or more patterns.An internal command used in replication.Returns the expiration time in milliseconds of a key.Posts a message to a channel.A container for Pub/Sub commands.punsubscribe(List<String> args) Stops listening to messages published to channels that match one or more patterns.Closes the connection.Returns a random key name from the database.readonly()Enables read-only queries for a connection to a Valkey replica node.Enables read-write queries for a connection to a Valkey replica node.Renames a key and overwrites the destination.Renames a key only when the target key name doesn't exist.An internal command for configuring the replication stream.Configures a server as replica of another, or promotes it to a primary.reset()Resets the connection.Creates a key from the serialized representation of a value.restoreAsking(List<String> args) An internal command for migrating keys in a cluster.role()Returns the replication role.Returns and removes one or more elements from the end of a list.Returns the last element of a list after removing and pushing it to another list.Appends one or more elements to a list.Appends one or more elements to a list only when the list exists.A container for Access List Control commands.Appends a string to the value of a key.rxAsking()Signals that a cluster client is following an -ASK redirect.Authenticates the connection.Asynchronously rewrites the append-only file to disk.Asynchronously saves the database(s) to disk.rxBitcount(List<String> args) Counts the number of set bits (population counting) in a string.rxBitfield(List<String> args) Performs arbitrary bitfield integer operations on strings.rxBitfieldRo(List<String> args) Performs arbitrary read-only bitfield integer operations on strings.Performs bitwise operations on multiple strings, and stores the result.Finds the first set (1) or clear (0) bit in a string.Pops an element from a list, pushes it to another list and returns it.Pops the first element from one of multiple lists.Removes and returns the first element in a list.Removes and returns the last element in a list.rxBrpoplpush(String arg0, String arg1, String arg2) Pops an element from a list, pushes it to another list and returns it.Removes and returns a member by score from one or more sorted sets.rxBzpopmax(List<String> args) Removes and returns the member with the highest score from one or more sorted sets.rxBzpopmin(List<String> args) Removes and returns the member with the lowest score from one or more sorted sets.A container for client connection commands.A container for Cluster commands.Returns detailed information about all commands.rxCommandlog(List<String> args) A container for command log commands.A container for server configuration commands.Copies the value of a key to a new key.rxDbsize()Returns the number of keys in the database.A container for debugging commands.Decrements the integer value of a key by one.Decrements a number from the integer value of a key.Deletes one or more keys.Delete key if value matches string.Discards a transaction.Returns a serialized representation of the value stored at a key.Returns the given string.Executes a server-side Lua script.Executes a read-only server-side Lua script.Executes a server-side Lua script by SHA1 digest.rxEvalshaRo(List<String> args) Executes a read-only server-side Lua script by SHA1 digest.rxExec()Executes all commands in a transaction.Determines whether one or more keys exist.Sets the expiration time of a key in seconds.rxExpireat(List<String> args) Sets the expiration time of a key to a Unix timestamp.rxExpiretime(String arg0) Returns the expiration time of a key as a Unix timestamp.rxFailover(List<String> args) Starts a coordinated failover from a server to one of its replicas.Invokes a function.Invokes a read-only function.rxFlushall(List<String> args) Removes all keys from all databases.Remove all keys from the current database.rxFunction(List<String> args) A container for function commands.Adds one or more members to a geospatial index.Returns the distance between two members of a geospatial index.Returns members from a geospatial index as geohash strings.Returns the longitude and latitude of members from a geospatial index.rxGeoradius(List<String> args) Queries a geospatial index for members within a distance from a coordinate, optionally stores the result.rxGeoradiusbymember(List<String> args) Queries a geospatial index for members within a distance from a member, optionally stores the result.rxGeoradiusbymemberRo(List<String> args) Returns members from a geospatial index that are within a distance from a member.rxGeoradiusRo(List<String> args) Returns members from a geospatial index that are within a distance from a coordinate.rxGeosearch(List<String> args) Queries a geospatial index for members inside an area of a box, circle, or a polygon.rxGeosearchstore(List<String> args) Queries a geospatial index for members inside an area of a box, a circle, or a polygon, optionally stores the result.Returns the string value of a key.Returns a bit value by offset.Returns the string value of a key after deleting the key.Returns the string value of a key after setting its expiration time.rxGetrange(String arg0, String arg1, String arg2) Returns a substring of the string stored at a key.Returns the previous string value of a key after setting it to a new value.Deletes one or more fields and their values from a hash.Handshakes with the server.Determines whether a field exists in a hash.Set expiry time on hash fields.rxHexpireat(List<String> args) Set expiry time on hash fields.rxHexpiretime(List<String> args) Returns Unix timestamps in seconds since the epoch at which the given key's field(s) will expire.Returns the value of a field in a hash.Returns all fields and values in a hash.Get the value of one or more fields of a given hash key, and optionally set their expiration time or time-to-live (TTL).Increments the integer value of a field in a hash by a number.rxHincrbyfloat(String arg0, String arg1, String arg2) Increments the floating point value of a field by a number.Returns all fields in a hash.Returns the number of fields in a hash.Returns the values of all fields in a hash.Sets the values of multiple fields.rxHpersist(List<String> args) Remove the existing expiration on a hash key's field(s).rxHpexpire(List<String> args) Set expiry time on hash object.rxHpexpireat(List<String> args) Set expiration time on hash field.rxHpexpiretime(List<String> args) Returns the Unix timestamp in milliseconds since Unix epoch at which the given key's field(s) will expire.Returns the remaining time to live in milliseconds of a hash key's field(s) that have an associated expiration.rxHrandfield(List<String> args) Returns one or more random fields from a hash.Iterates over fields and values of a hash.Creates or modifies the value of a field in a hash.Set the value of one or more fields of a given hash key, and optionally set their expiration time.Sets the value of a field in a hash only when the field doesn't exist.Returns the length of the value of a field.Returns the remaining time to live (in seconds) of a hash key's field(s) that have an associated expiration.Returns all values in a hash.Increments the integer value of a key by one.Increments the integer value of a key by a number.rxIncrbyfloat(String arg0, String arg1) Increment the floating point value of a key by a number.Returns information and statistics about the server.Returns all key names that match a pattern.Returns the Unix timestamp of the last successful save to disk.A container for latency diagnostics commands.Finds the longest common substring.Returns an element from a list by its index.Inserts an element before or after another element in a list.Returns the length of a list.Returns an element after popping it from one list and pushing it to another.Returns multiple elements from a list after removing them.Displays computer art and the server version.Returns and removes one or more elements from the beginning of a list.Returns the index of matching elements in a list.Prepends one or more elements to a list.Prepends one or more elements to a list only when the list exists.Returns a range of elements from a list.Removes elements from a list.Sets the value of an element in a list by its index.Removes elements from both ends a list.A container for memory diagnostics commands.Atomically returns the string values of one or more keys.Atomically transfers a key from one instance to another.A container for module commands.Listens for all requests received by the server in real-time.Moves a key to another database.Atomically creates or modifies the string values of one or more keys.Atomically modifies the string values of one or more keys only when all keys don't exist.rxMulti()Starts a transaction.A container for object introspection commands.Removes the expiration time of a key.Sets the expiration time of a key in milliseconds.rxPexpireat(List<String> args) Sets the expiration time of a key to a Unix milliseconds timestamp.rxPexpiretime(String arg0) Returns the expiration time of a key as a Unix milliseconds timestamp.Adds elements to a HyperLogLog key.Returns the approximated cardinality of the set(s) observed by the HyperLogLog key(s).Internal commands for debugging HyperLogLog values.Merges one or more HyperLogLog values into a single key.An internal command for testing HyperLogLog values.Returns the server's liveliness response.Sets both string value and expiration time in milliseconds of a key.rxPsubscribe(List<String> args) Listens for messages published to channels that match one or more patterns.An internal command used in replication.Returns the expiration time in milliseconds of a key.Posts a message to a channel.A container for Pub/Sub commands.rxPunsubscribe(List<String> args) Stops listening to messages published to channels that match one or more patterns.Closes the connection.Returns a random key name from the database.Enables read-only queries for a connection to a Valkey replica node.Enables read-write queries for a connection to a Valkey replica node.Renames a key and overwrites the destination.rxRenamenx(String arg0, String arg1) Renames a key only when the target key name doesn't exist.rxReplconf(List<String> args) An internal command for configuring the replication stream.rxReplicaof(String arg0, String arg1) Configures a server as replica of another, or promotes it to a primary.rxReset()Resets the connection.Creates a key from the serialized representation of a value.rxRestoreAsking(List<String> args) An internal command for migrating keys in a cluster.rxRole()Returns the replication role.Returns and removes one or more elements from the end of a list.rxRpoplpush(String arg0, String arg1) Returns the last element of a list after removing and pushing it to another list.Appends one or more elements to a list.Appends one or more elements to a list only when the list exists.Adds one or more members to a set.rxSave()Synchronously saves the database(s) to disk.Iterates over the key names in the database.Returns the number of members in a set.A container for Lua scripts management commands.Returns the difference of multiple sets.rxSdiffstore(List<String> args) Stores the difference of multiple sets in a key.Changes the selected database.Sets the string value of a key, ignoring its type.Sets or clears the bit at offset of the string value.Sets the string value and expiration time of a key.Set the string value of a key only when the key doesn't exist.rxSetrange(String arg0, String arg1, String arg2) Overwrites a part of a string value with another by an offset.rxShutdown(List<String> args) Synchronously saves the database(s) to disk and shuts down the server.Returns the intersect of multiple sets.rxSintercard(List<String> args) Returns the number of members of the intersect of multiple sets.rxSinterstore(List<String> args) Stores the intersect of multiple sets in a key.rxSismember(String arg0, String arg1) Determines whether a member belongs to a set.Sets a server as a replica of another, or promotes it to being a primary.A container for slow log commands.rxSmembers(String arg0) Returns all members of a set.rxSmismember(List<String> args) Determines whether multiple members belong to a set.Moves a member from one set to another.Sorts the elements in a list, a set, or a sorted set, optionally storing the result.Returns the sorted elements of a list, a set, or a sorted set.Returns one or more random members from a set after removing them.rxSpublish(String arg0, String arg1) Post a message to a shard channel.rxSrandmember(List<String> args) Get one or multiple random members from a set.Removes one or more members from a set.Iterates over members of a set.rxSsubscribe(List<String> args) Listens for messages published to shard channels.Returns the length of a string value.rxSubscribe(List<String> args) Listens for messages published to channels.Returns a substring from a string value.Returns the union of multiple sets.rxSunionstore(List<String> args) Stores the union of multiple sets in a key.rxSunsubscribe(List<String> args) Stops listening to messages posted to shard channels.Swaps two databases.rxSync()An internal command used in replication.rxTime()Returns the server time.Returns the number of existing keys out of those specified after updating the time they were last accessed.Returns the expiration time in seconds of a key.Determines the type of value stored at a key.Asynchronously deletes one or more keys.rxUnsubscribe(List<String> args) Stops listening to messages posted to channels.Forgets about watched keys of a transaction.Blocks until the asynchronous replication of all preceding write commands sent by the connection is completed.Blocks until all of the preceding write commands sent by the connection are written to the append-only file of the primary and/or replicas.Monitors changes to keys to determine the execution of a transaction.Returns the number of messages that were successfully acknowledged by the consumer group member of a stream.Appends a new message to a stream.rxXautoclaim(List<String> args) Changes, or acquires, ownership of messages in a consumer group, as if the messages were delivered to as consumer group member.Changes, or acquires, ownership of a message in a consumer group, as if the message was delivered a consumer group member.Returns the number of messages after removing them from a stream.A container for consumer groups commands.A container for stream introspection commands.Return the number of messages in a stream.rxXpending(List<String> args) Returns the information and entries from a stream consumer group's pending entries list.Returns the messages from a stream within a range of IDs.Returns messages from multiple streams with IDs greater than the ones requested.rxXreadgroup(List<String> args) Returns new or historical messages from a stream for a consumer in a group.rxXrevrange(List<String> args) Returns the messages from a stream within a range of IDs in reverse order.An internal command for replicating stream values.Deletes messages from the beginning of a stream.Adds one or more members to a sorted set, or updates their scores.Returns the number of members in a sorted set.Returns the count of members in a sorted set that have scores within a range.Returns the difference between multiple sorted sets.rxZdiffstore(List<String> args) Stores the difference of multiple sorted sets in a key.Increments the score of a member in a sorted set.Returns the intersect of multiple sorted sets.rxZintercard(List<String> args) Returns the number of members of the intersect of multiple sorted sets.rxZinterstore(List<String> args) Stores the intersect of multiple sorted sets in a key.rxZlexcount(String arg0, String arg1, String arg2) Returns the number of members in a sorted set within a lexicographical range.Returns the highest- or lowest-scoring members from one or more sorted sets after removing them.Returns the score of one or more members in a sorted set.Returns the highest-scoring members from a sorted set after removing them.Returns the lowest-scoring members from a sorted set after removing them.rxZrandmember(List<String> args) Returns one or more random members from a sorted set.Returns members in a sorted set within a range of indexes.rxZrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range.rxZrangebyscore(List<String> args) Returns members in a sorted set within a range of scores.rxZrangestore(List<String> args) Stores a range of members from sorted set in a key.Returns the index of a member in a sorted set ordered by ascending scores.Removes one or more members from a sorted set.rxZremrangebylex(String arg0, String arg1, String arg2) Removes members in a sorted set within a lexicographical range.rxZremrangebyrank(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of indexes.rxZremrangebyscore(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of scores.rxZrevrange(List<String> args) Returns members in a sorted set within a range of indexes in reverse order.rxZrevrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range in reverse order.rxZrevrangebyscore(List<String> args) Returns members in a sorted set within a range of scores in reverse order.rxZrevrank(List<String> args) Returns the index of a member in a sorted set ordered by descending scores.Iterates over members and scores of a sorted set.Returns the score of a member in a sorted set.Returns the union of multiple sorted sets.rxZunionstore(List<String> args) Stores the union of multiple sorted sets in a key.Adds one or more members to a set.save()Synchronously saves the database(s) to disk.Iterates over the key names in the database.Returns the number of members in a set.A container for Lua scripts management commands.Returns the difference of multiple sets.sdiffstore(List<String> args) Stores the difference of multiple sets in a key.Changes the selected database.Sets the string value of a key, ignoring its type.Sets or clears the bit at offset of the string value.Sets the string value and expiration time of a key.Set the string value of a key only when the key doesn't exist.Overwrites a part of a string value with another by an offset.Synchronously saves the database(s) to disk and shuts down the server.Returns the intersect of multiple sets.sintercard(List<String> args) Returns the number of members of the intersect of multiple sets.sinterstore(List<String> args) Stores the intersect of multiple sets in a key.Determines whether a member belongs to a set.Sets a server as a replica of another, or promotes it to being a primary.A container for slow log commands.Returns all members of a set.smismember(List<String> args) Determines whether multiple members belong to a set.Moves a member from one set to another.Sorts the elements in a list, a set, or a sorted set, optionally storing the result.Returns the sorted elements of a list, a set, or a sorted set.Returns one or more random members from a set after removing them.Post a message to a shard channel.srandmember(List<String> args) Get one or multiple random members from a set.Removes one or more members from a set.Iterates over members of a set.ssubscribe(List<String> args) Listens for messages published to shard channels.Returns the length of a string value.Listens for messages published to channels.Returns a substring from a string value.Returns the union of multiple sets.sunionstore(List<String> args) Stores the union of multiple sets in a key.sunsubscribe(List<String> args) Stops listening to messages posted to shard channels.Swaps two databases.sync()An internal command used in replication.time()Returns the server time.toString()Returns the number of existing keys out of those specified after updating the time they were last accessed.Returns the expiration time in seconds of a key.Determines the type of value stored at a key.Asynchronously deletes one or more keys.unsubscribe(List<String> args) Stops listening to messages posted to channels.unwatch()Forgets about watched keys of a transaction.Blocks until the asynchronous replication of all preceding write commands sent by the connection is completed.Blocks until all of the preceding write commands sent by the connection are written to the append-only file of the primary and/or replicas.Monitors changes to keys to determine the execution of a transaction.Returns the number of messages that were successfully acknowledged by the consumer group member of a stream.Appends a new message to a stream.xautoclaim(List<String> args) Changes, or acquires, ownership of messages in a consumer group, as if the messages were delivered to as consumer group member.Changes, or acquires, ownership of a message in a consumer group, as if the message was delivered a consumer group member.Returns the number of messages after removing them from a stream.A container for consumer groups commands.A container for stream introspection commands.Return the number of messages in a stream.Returns the information and entries from a stream consumer group's pending entries list.Returns the messages from a stream within a range of IDs.Returns messages from multiple streams with IDs greater than the ones requested.xreadgroup(List<String> args) Returns new or historical messages from a stream for a consumer in a group.Returns the messages from a stream within a range of IDs in reverse order.An internal command for replicating stream values.Deletes messages from the beginning of a stream.Adds one or more members to a sorted set, or updates their scores.Returns the number of members in a sorted set.Returns the count of members in a sorted set that have scores within a range.Returns the difference between multiple sorted sets.zdiffstore(List<String> args) Stores the difference of multiple sorted sets in a key.Increments the score of a member in a sorted set.Returns the intersect of multiple sorted sets.zintercard(List<String> args) Returns the number of members of the intersect of multiple sorted sets.zinterstore(List<String> args) Stores the intersect of multiple sorted sets in a key.Returns the number of members in a sorted set within a lexicographical range.Returns the highest- or lowest-scoring members from one or more sorted sets after removing them.Returns the score of one or more members in a sorted set.Returns the highest-scoring members from a sorted set after removing them.Returns the lowest-scoring members from a sorted set after removing them.zrandmember(List<String> args) Returns one or more random members from a sorted set.Returns members in a sorted set within a range of indexes.zrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range.zrangebyscore(List<String> args) Returns members in a sorted set within a range of scores.zrangestore(List<String> args) Stores a range of members from sorted set in a key.Returns the index of a member in a sorted set ordered by ascending scores.Removes one or more members from a sorted set.zremrangebylex(String arg0, String arg1, String arg2) Removes members in a sorted set within a lexicographical range.zremrangebyrank(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of indexes.zremrangebyscore(String arg0, String arg1, String arg2) Removes members in a sorted set within a range of scores.Returns members in a sorted set within a range of indexes in reverse order.zrevrangebylex(List<String> args) Returns members in a sorted set within a lexicographical range in reverse order.zrevrangebyscore(List<String> args) Returns members in a sorted set within a range of scores in reverse order.Returns the index of a member in a sorted set ordered by descending scores.Iterates over members and scores of a sorted set.Returns the score of a member in a sorted set.Returns the union of multiple sorted sets.zunionstore(List<String> args) Stores the union of multiple sorted sets in a key.
-
Field Details
-
__TYPE_ARG
-
-
Constructor Details
-
ValkeyAPI
-
ValkeyAPI
-
-
Method Details
-
toString
-
equals
-
hashCode
-
getDelegate
- Specified by:
getDelegatein interfaceio.vertx.lang.rx.RxDelegate
-
close
public void close() -
acl
-
rxAcl
-
append
-
rxAppend
-
asking
-
rxAsking
-
auth
-
rxAuth
-
bgrewriteaof
-
rxBgrewriteaof
-
bgsave
-
rxBgsave
-
bitcount
-
rxBitcount
-
bitfield
-
rxBitfield
-
bitfieldRo
-
rxBitfieldRo
-
bitop
-
rxBitop
-
bitpos
-
rxBitpos
-
blmove
Pops an element from a list, pushes it to another list and returns it. Blocks until an element is available otherwise. Deletes the list if the last element was moved.- Parameters:
arg0-arg1-arg2-arg3-arg4-- Returns:
-
rxBlmove
Pops an element from a list, pushes it to another list and returns it. Blocks until an element is available otherwise. Deletes the list if the last element was moved.- Parameters:
arg0-arg1-arg2-arg3-arg4-- Returns:
-
blmpop
-
rxBlmpop
-
blpop
-
rxBlpop
-
brpop
-
rxBrpop
-
brpoplpush
-
rxBrpoplpush
-
bzmpop
-
rxBzmpop
-
bzpopmax
-
rxBzpopmax
-
bzpopmin
-
rxBzpopmin
-
client
-
rxClient
-
cluster
-
rxCluster
-
command
-
rxCommand
-
commandlog
-
rxCommandlog
-
config
-
rxConfig
-
copy
-
rxCopy
-
dbsize
-
rxDbsize
-
debug
-
rxDebug
-
decr
-
rxDecr
-
decrby
-
rxDecrby
-
del
-
rxDel
-
delifeq
-
rxDelifeq
-
discard
-
rxDiscard
-
dump
-
rxDump
-
echo
-
rxEcho
-
eval
-
rxEval
-
evalRo
-
rxEvalRo
-
evalsha
-
rxEvalsha
-
evalshaRo
-
rxEvalshaRo
-
exec
-
rxExec
-
exists
-
rxExists
-
expire
-
rxExpire
-
expireat
-
rxExpireat
-
expiretime
-
rxExpiretime
-
failover
-
rxFailover
-
fcall
-
rxFcall
-
fcallRo
-
rxFcallRo
-
flushall
-
rxFlushall
-
flushdb
-
rxFlushdb
-
function
-
rxFunction
-
geoadd
-
rxGeoadd
-
geodist
-
rxGeodist
-
geohash
-
rxGeohash
-
geopos
-
rxGeopos
-
georadius
-
rxGeoradius
-
georadiusRo
-
rxGeoradiusRo
-
georadiusbymember
-
rxGeoradiusbymember
-
georadiusbymemberRo
-
rxGeoradiusbymemberRo
-
geosearch
-
rxGeosearch
-
geosearchstore
-
rxGeosearchstore
-
get
-
rxGet
-
getbit
-
rxGetbit
-
getdel
-
rxGetdel
-
getex
-
rxGetex
-
getrange
-
rxGetrange
-
getset
-
rxGetset
-
hdel
-
rxHdel
-
hello
-
rxHello
-
hexists
-
rxHexists
-
hexpire
-
rxHexpire
-
hexpireat
-
rxHexpireat
-
hexpiretime
-
rxHexpiretime
-
hget
-
rxHget
-
hgetall
-
rxHgetall
-
hgetex
-
rxHgetex
-
hincrby
-
rxHincrby
-
hincrbyfloat
-
rxHincrbyfloat
-
hkeys
-
rxHkeys
-
hlen
-
rxHlen
-
hmget
-
rxHmget
-
hmset
-
rxHmset
-
hpersist
-
rxHpersist
-
hpexpire
-
rxHpexpire
-
hpexpireat
-
rxHpexpireat
-
hpexpiretime
-
rxHpexpiretime
-
hpttl
-
rxHpttl
-
hrandfield
-
rxHrandfield
-
hscan
-
rxHscan
-
hset
-
rxHset
-
hsetex
-
rxHsetex
-
hsetnx
-
rxHsetnx
-
hstrlen
-
rxHstrlen
-
httl
-
rxHttl
-
hvals
-
rxHvals
-
incr
-
rxIncr
-
incrby
-
rxIncrby
-
incrbyfloat
-
rxIncrbyfloat
-
info
-
rxInfo
-
keys
-
rxKeys
-
lastsave
-
rxLastsave
-
latency
-
rxLatency
-
lcs
-
rxLcs
-
lindex
-
rxLindex
-
linsert
-
rxLinsert
-
llen
-
rxLlen
-
lmove
-
rxLmove
-
lmpop
-
rxLmpop
-
lolwut
-
rxLolwut
-
lpop
-
rxLpop
-
lpos
-
rxLpos
-
lpush
-
rxLpush
-
lpushx
-
rxLpushx
-
lrange
-
rxLrange
-
lrem
-
rxLrem
-
lset
-
rxLset
-
ltrim
-
rxLtrim
-
memory
-
rxMemory
-
mget
-
rxMget
-
migrate
-
rxMigrate
-
module
-
rxModule
-
monitor
-
rxMonitor
-
move
-
rxMove
-
mset
-
rxMset
-
msetnx
-
rxMsetnx
-
multi
-
rxMulti
-
object
-
rxObject
-
persist
-
rxPersist
-
pexpire
-
rxPexpire
-
pexpireat
-
rxPexpireat
-
pexpiretime
-
rxPexpiretime
-
pfadd
-
rxPfadd
-
pfcount
-
rxPfcount
-
pfdebug
-
rxPfdebug
-
pfmerge
-
rxPfmerge
-
pfselftest
-
rxPfselftest
-
ping
-
rxPing
-
psetex
-
rxPsetex
-
psubscribe
-
rxPsubscribe
-
psync
-
rxPsync
-
pttl
-
rxPttl
-
publish
-
rxPublish
-
pubsub
-
rxPubsub
-
punsubscribe
-
rxPunsubscribe
-
quit
-
rxQuit
-
randomkey
-
rxRandomkey
-
readonly
-
rxReadonly
-
readwrite
-
rxReadwrite
-
rename
-
rxRename
-
renamenx
-
rxRenamenx
-
replconf
-
rxReplconf
-
replicaof
-
rxReplicaof
-
reset
-
rxReset
-
restore
-
rxRestore
-
restoreAsking
-
rxRestoreAsking
-
role
-
rxRole
-
rpop
-
rxRpop
-
rpoplpush
-
rxRpoplpush
-
rpush
-
rxRpush
-
rpushx
-
rxRpushx
-
sadd
-
rxSadd
-
save
-
rxSave
-
scan
-
rxScan
-
scard
-
rxScard
-
script
-
rxScript
-
sdiff
-
rxSdiff
-
sdiffstore
-
rxSdiffstore
-
select
-
rxSelect
-
set
-
rxSet
-
setbit
-
rxSetbit
-
setex
-
rxSetex
-
setnx
-
rxSetnx
-
setrange
-
rxSetrange
-
shutdown
-
rxShutdown
-
sinter
-
rxSinter
-
sintercard
-
rxSintercard
-
sinterstore
-
rxSinterstore
-
sismember
-
rxSismember
-
slaveof
-
rxSlaveof
-
slowlog
-
rxSlowlog
-
smembers
-
rxSmembers
-
smismember
-
rxSmismember
-
smove
-
rxSmove
-
sort
-
rxSort
-
sortRo
-
rxSortRo
-
spop
-
rxSpop
-
spublish
-
rxSpublish
-
srandmember
-
rxSrandmember
-
srem
-
rxSrem
-
sscan
-
rxSscan
-
ssubscribe
-
rxSsubscribe
-
strlen
-
rxStrlen
-
subscribe
-
rxSubscribe
-
substr
-
rxSubstr
-
sunion
-
rxSunion
-
sunionstore
-
rxSunionstore
-
sunsubscribe
-
rxSunsubscribe
-
swapdb
-
rxSwapdb
-
sync
-
rxSync
-
time
-
rxTime
-
touch
-
rxTouch
-
ttl
-
rxTtl
-
type
-
rxType
-
unlink
-
rxUnlink
-
unsubscribe
-
rxUnsubscribe
-
unwatch
-
rxUnwatch
-
wait
-
rxWait
-
waitaof
-
rxWaitaof
-
watch
-
rxWatch
-
xack
-
rxXack
-
xadd
-
rxXadd
-
xautoclaim
-
rxXautoclaim
-
xclaim
-
rxXclaim
-
xdel
-
rxXdel
-
xgroup
-
rxXgroup
-
xinfo
-
rxXinfo
-
xlen
-
rxXlen
-
xpending
-
rxXpending
-
xrange
-
rxXrange
-
xread
-
rxXread
-
xreadgroup
-
rxXreadgroup
-
xrevrange
-
rxXrevrange
-
xsetid
-
rxXsetid
-
xtrim
-
rxXtrim
-
zadd
-
rxZadd
-
zcard
-
rxZcard
-
zcount
-
rxZcount
-
zdiff
-
rxZdiff
-
zdiffstore
-
rxZdiffstore
-
zincrby
-
rxZincrby
-
zinter
-
rxZinter
-
zintercard
-
rxZintercard
-
zinterstore
-
rxZinterstore
-
zlexcount
-
rxZlexcount
-
zmpop
-
rxZmpop
-
zmscore
-
rxZmscore
-
zpopmax
-
rxZpopmax
-
zpopmin
-
rxZpopmin
-
zrandmember
-
rxZrandmember
-
zrange
-
rxZrange
-
zrangebylex
-
rxZrangebylex
-
zrangebyscore
-
rxZrangebyscore
-
zrangestore
-
rxZrangestore
-
zrank
-
rxZrank
-
zrem
-
rxZrem
-
zremrangebylex
-
rxZremrangebylex
-
zremrangebyrank
-
rxZremrangebyrank
-
zremrangebyscore
-
rxZremrangebyscore
-
zrevrange
-
rxZrevrange
-
zrevrangebylex
-
rxZrevrangebylex
-
zrevrangebyscore
-
rxZrevrangebyscore
-
zrevrank
-
rxZrevrank
-
zscan
-
rxZscan
-
zscore
-
rxZscore
-
zunion
-
rxZunion
-
zunionstore
-
rxZunionstore
-
api
-
api
-
newInstance
-