Modifier and Type | Method and Description |
---|---|
JsonArray |
Buffer.toJsonArray()
Returns a Json array representation of the Buffer
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonArray.add(Boolean value)
Add a Boolean to the JSON array.
|
JsonArray |
JsonArray.add(byte[] value)
Add a binary value to the JSON array.
|
JsonArray |
JsonArray.add(CharSequence value)
Add a CharSequence to the JSON array.
|
JsonArray |
JsonArray.add(Double value)
Add a Double to the JSON array.
|
JsonArray |
JsonArray.add(Enum value)
Add an enum to the JSON array.
|
JsonArray |
JsonArray.add(Float value)
Add a Float to the JSON array.
|
JsonArray |
JsonArray.add(java.time.Instant value)
Add a Instant value to the JSON array.
|
JsonArray |
JsonArray.add(Integer value)
Add an Integer to the JSON array.
|
JsonArray |
JsonArray.add(JsonArray value)
Add another JSON array to the JSON array.
|
JsonArray |
JsonArray.add(JsonObject value)
Add a JSON object to the JSON array.
|
JsonArray |
JsonArray.add(Long value)
Add a Long to the JSON array.
|
JsonArray |
JsonArray.add(Object value)
Add an Object to the JSON array.
|
JsonArray |
JsonArray.add(String value)
Add a String to the JSON array.
|
JsonArray |
JsonArray.addAll(JsonArray array)
Appends all of the elements in the specified array to the end of this JSON array.
|
JsonArray |
JsonArray.addNull()
Add a null value to the JSON array.
|
JsonArray |
JsonArray.clear()
Remove all entries from the JSON array
|
JsonArray |
JsonArray.copy()
Make a copy of the JSON array
|
JsonArray |
JsonArray.getJsonArray(int pos)
Get the JsonArray at position
pos in the array. |
JsonArray |
JsonObject.getJsonArray(String key)
Get the JsonArray value with the specified key
|
JsonArray |
JsonObject.getJsonArray(String key,
JsonArray def)
Like
JsonObject.getJsonArray(String) but specifying a default value to return if there is no entry. |
Modifier and Type | Method and Description |
---|---|
JsonArray |
JsonArray.add(JsonArray value)
Add another JSON array to the JSON array.
|
JsonArray |
JsonArray.addAll(JsonArray array)
Appends all of the elements in the specified array to the end of this JSON array.
|
JsonArray |
JsonObject.getJsonArray(String key,
JsonArray def)
Like
JsonObject.getJsonArray(String) but specifying a default value to return if there is no entry. |
JsonObject |
JsonObject.put(String key,
JsonArray value)
Put a JSON array into the JSON object with the specified key.
|
Modifier and Type | Method and Description |
---|---|
String |
JDBCHashStrategy.getHashedStoredPwd(JsonArray row)
Retrieve the hashed password from the result of the authentication query
|
String |
JDBCHashStrategy.getSalt(JsonArray row)
Retrieve the salt from the result of the authentication query
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
UpdateResult.getKeys()
Get any generated keys
|
JsonArray |
ResultSet.getOutput()
Get the registered outputs
|
Modifier and Type | Method and Description |
---|---|
List<JsonArray> |
ResultSet.getResults()
Get the results
|
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
UpdateResult |
UpdateResult.setKeys(JsonArray keys) |
ResultSet |
ResultSet.setOutput(JsonArray output) |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args,
Handler<AsyncResult<List<Integer>>> handler)
Batch a prepared statement with all entries from the args list.
|
ResultSet |
ResultSet.setResults(List<JsonArray> results) |
Constructor and Description |
---|
UpdateResult(int updated,
JsonArray keys)
Constructor
|
Constructor and Description |
---|
ResultSet(List<String> columnNames,
List<JsonArray> results)
Create a result-set
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
RoutingContext.getBodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
RedisClient |
RedisClient.blpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in a list, or block until one is available
|
RedisClient |
RedisClient.blpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in any of the lists, or block until one is available
|
RedisClient |
RedisClient.brpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in a list, or block until one is available
|
RedisClient |
RedisClient.brpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in any of the lists, or block until one is available
|
RedisClient |
RedisClient.clusterGetkeysinslot(long slot,
long count,
Handler<AsyncResult<JsonArray>> handler)
Return local key names in the specified hash slot.
|
RedisClient |
RedisClient.clusterInfo(Handler<AsyncResult<JsonArray>> handler)
Provides info about Redis Cluster node state.
|
RedisClient |
RedisClient.clusterNodes(Handler<AsyncResult<JsonArray>> handler)
Get Cluster config for the node.
|
RedisClient |
RedisClient.clusterSlaves(String nodeId,
Handler<AsyncResult<JsonArray>> handler)
List slave nodes of the specified master node.
|
RedisClient |
RedisClient.clusterSlots(Handler<AsyncResult<JsonArray>> handler)
Get array of Cluster slot to node mappings
|
RedisClient |
RedisClient.command(Handler<AsyncResult<JsonArray>> handler)
Get array of Redis command details
|
RedisClient |
RedisClient.commandGetkeys(Handler<AsyncResult<JsonArray>> handler)
Extract keys given a full Redis command
|
RedisClient |
RedisClient.commandInfo(List<String> commands,
Handler<AsyncResult<JsonArray>> handler)
Get array of specific Redis command details
|
RedisClient |
RedisClient.configGet(String parameter,
Handler<AsyncResult<JsonArray>> handler)
Get the value of a configuration parameter
|
RedisClient |
RedisClient.eval(String script,
List<String> keys,
List<String> args,
Handler<AsyncResult<JsonArray>> handler)
Execute a Lua script server side.
|
RedisClient |
RedisClient.evalsha(String sha1,
List<String> keys,
List<String> values,
Handler<AsyncResult<JsonArray>> handler)
Execute a Lua script server side.
|
RedisTransaction |
RedisTransaction.exec(Handler<AsyncResult<JsonArray>> handler)
Execute all commands issued after MULTI
|
RedisClient |
RedisClient.geohash(String key,
String member,
Handler<AsyncResult<JsonArray>> handler)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
RedisClient |
RedisClient.geohashMany(String key,
List<String> members,
Handler<AsyncResult<JsonArray>> handler)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
RedisClient |
RedisClient.geopos(String key,
String member,
Handler<AsyncResult<JsonArray>> handler)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
RedisClient |
RedisClient.geoposMany(String key,
List<String> members,
Handler<AsyncResult<JsonArray>> handler)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
RedisClient |
RedisClient.georadius(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
Handler<AsyncResult<JsonArray>> handler)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
RedisClient |
RedisClient.georadiusbymember(String key,
String member,
double radius,
GeoUnit unit,
Handler<AsyncResult<JsonArray>> handler)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
RedisClient |
RedisClient.georadiusbymemberWithOptions(String key,
String member,
double radius,
GeoUnit unit,
GeoRadiusOptions options,
Handler<AsyncResult<JsonArray>> handler)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
RedisClient |
RedisClient.georadiusWithOptions(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
GeoRadiusOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
RedisClient |
RedisClient.hkeys(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the fields in a hash
|
RedisClient |
RedisClient.hmget(String key,
List<String> fields,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given hash fields
|
RedisClient |
RedisClient.hscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate hash fields and associated values
|
RedisClient |
RedisClient.hvals(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the values in a hash
|
RedisClient |
RedisClient.keys(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Find all keys matching the given pattern
|
RedisClient |
RedisClient.lrange(String key,
long from,
long to,
Handler<AsyncResult<JsonArray>> handler)
Get a range of elements from a list
|
RedisClient |
RedisClient.mget(String key,
Handler<AsyncResult<JsonArray>> handler)
Get the value of the given key
|
RedisClient |
RedisClient.mgetMany(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given keys
|
RedisClient |
RedisClient.psubscribe(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to channels matching the given pattern
|
RedisClient |
RedisClient.psubscribeMany(List<String> patterns,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to channels matching the given patterns
|
RedisClient |
RedisClient.pubsubChannels(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Lists the currently active channels - only those matching the pattern
|
RedisClient |
RedisClient.pubsubNumsub(List<String> channels,
Handler<AsyncResult<JsonArray>> handler)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
RedisClient |
RedisClient.role(Handler<AsyncResult<JsonArray>> handler)
Return the role of the instance in the context of replication
|
RedisClient |
RedisClient.scan(String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate the keys space
|
RedisClient |
RedisClient.scriptExists(String script,
Handler<AsyncResult<JsonArray>> handler)
Check existence of script in the script cache.
|
RedisClient |
RedisClient.scriptExistsMany(List<String> scripts,
Handler<AsyncResult<JsonArray>> handler)
Check existence of scripts in the script cache.
|
RedisClient |
RedisClient.sdiff(String key,
List<String> cmpkeys,
Handler<AsyncResult<JsonArray>> handler)
Subtract multiple sets
|
RedisClient |
RedisClient.sinter(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Intersect multiple sets
|
RedisClient |
RedisClient.slowlogGet(int limit,
Handler<AsyncResult<JsonArray>> handler)
Read the Redis slow queries log
|
RedisClient |
RedisClient.smembers(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the members in a set
|
RedisClient |
RedisClient.sort(String key,
SortOptions options,
Handler<AsyncResult<JsonArray>> handler)
Sort the elements in a list, set or sorted set
|
RedisClient |
RedisClient.spopMany(String key,
int count,
Handler<AsyncResult<JsonArray>> handler)
Remove and return random members from a set
|
RedisClient |
RedisClient.srandmemberCount(String key,
int count,
Handler<AsyncResult<JsonArray>> handler)
Get one or multiple random members from a set
|
RedisClient |
RedisClient.sscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate Set elements
|
RedisClient |
RedisClient.subscribe(String channel,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to the given channels
|
RedisClient |
RedisClient.subscribeMany(List<String> channels,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to the given channels
|
RedisClient |
RedisClient.sunion(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Add multiple sets
|
RedisClient |
RedisClient.time(Handler<AsyncResult<JsonArray>> handler)
Return the current server time
|
RedisClient |
RedisClient.zrange(String key,
long start,
long stop,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
RedisClient.zrangebylex(String key,
String min,
String max,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by lexicographical range
|
RedisClient |
RedisClient.zrangebyscore(String key,
String min,
String max,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score
|
RedisClient |
RedisClient.zrangeWithOptions(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
RedisClient.zrevrange(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index, with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrangebylex(String key,
String max,
String min,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, between the given lexicographical range with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrangebyscore(String key,
String max,
String min,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, with scores ordered from high to low
|
RedisClient |
RedisClient.zscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate sorted sets elements and associated scores
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
AggregateOptions.toJsonArray() |
JsonArray |
GeoMember.toJsonArray() |
JsonArray |
GeoRadiusOptions.toJsonArray() |
JsonArray |
KillFilter.toJsonArray() |
JsonArray |
LimitOptions.toJsonArray() |
JsonArray |
MigrateOptions.toJsonArray() |
JsonArray |
RangeLimitOptions.toJsonArray() |
JsonArray |
RangeOptions.toJsonArray() |
JsonArray |
ScanOptions.toJsonArray() |
JsonArray |
SetOptions.toJsonArray() |
JsonArray |
ShutdownOptions.toJsonArray() |
JsonArray |
SortOptions.toJsonArray() |
Modifier and Type | Method and Description |
---|---|
JsonArray |
Buffer.toJsonArray()
Returns a Json array representation of the Buffer
|
Modifier and Type | Method and Description |
---|---|
Observable<JsonArray> |
MongoClient.distinctObservable(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
Observable<ResultSet> |
SQLConnection.callWithParamsObservable(String sql,
JsonArray params,
JsonArray outputs)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
Observable<ResultSet> |
SQLConnection.queryWithParamsObservable(String sql,
JsonArray params)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Observable<UpdateResult> |
SQLConnection.updateWithParamsObservable(String sql,
JsonArray params)
Executes the given prepared statement which may be an
INSERT , UPDATE , or DELETE
statement with the given parameters |
Modifier and Type | Method and Description |
---|---|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
Observable<List<Integer>> |
SQLConnection.batchCallableWithParamsObservable(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
Observable<List<Integer>> |
SQLConnection.batchCallableWithParamsObservable(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args,
Handler<AsyncResult<List<Integer>>> handler)
Batch a prepared statement with all entries from the args list.
|
Observable<List<Integer>> |
SQLConnection.batchWithParamsObservable(String sqlStatement,
List<JsonArray> args)
Batch a prepared statement with all entries from the args list.
|
Modifier and Type | Method and Description |
---|---|
JsonArray |
RoutingContext.getBodyAsJsonArray() |
Modifier and Type | Method and Description |
---|---|
Observable<JsonArray> |
RedisClient.blpopManyObservable(List<String> keys,
int seconds)
Remove and get the first element in any of the lists, or block until one is available
|
Observable<JsonArray> |
RedisClient.blpopObservable(String key,
int seconds)
Remove and get the first element in a list, or block until one is available
|
Observable<JsonArray> |
RedisClient.brpopManyObservable(List<String> keys,
int seconds)
Remove and get the last element in any of the lists, or block until one is available
|
Observable<JsonArray> |
RedisClient.brpopObservable(String key,
int seconds)
Remove and get the last element in a list, or block until one is available
|
Observable<JsonArray> |
RedisClient.clusterGetkeysinslotObservable(long slot,
long count)
Return local key names in the specified hash slot.
|
Observable<JsonArray> |
RedisClient.clusterInfoObservable()
Provides info about Redis Cluster node state.
|
Observable<JsonArray> |
RedisClient.clusterNodesObservable()
Get Cluster config for the node.
|
Observable<JsonArray> |
RedisClient.clusterSlavesObservable(String nodeId)
List slave nodes of the specified master node.
|
Observable<JsonArray> |
RedisClient.clusterSlotsObservable()
Get array of Cluster slot to node mappings
|
Observable<JsonArray> |
RedisClient.commandGetkeysObservable()
Extract keys given a full Redis command
|
Observable<JsonArray> |
RedisClient.commandInfoObservable(List<String> commands)
Get array of specific Redis command details
|
Observable<JsonArray> |
RedisClient.commandObservable()
Get array of Redis command details
|
Observable<JsonArray> |
RedisClient.configGetObservable(String parameter)
Get the value of a configuration parameter
|
Observable<JsonArray> |
RedisClient.evalObservable(String script,
List<String> keys,
List<String> args)
Execute a Lua script server side.
|
Observable<JsonArray> |
RedisClient.evalshaObservable(String sha1,
List<String> keys,
List<String> values)
Execute a Lua script server side.
|
Observable<JsonArray> |
RedisTransaction.execObservable()
Execute all commands issued after MULTI
|
Observable<JsonArray> |
RedisClient.geohashManyObservable(String key,
List<String> members)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
Observable<JsonArray> |
RedisClient.geohashObservable(String key,
String member)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
Observable<JsonArray> |
RedisClient.geoposManyObservable(String key,
List<String> members)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
Observable<JsonArray> |
RedisClient.geoposObservable(String key,
String member)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
Observable<JsonArray> |
RedisClient.georadiusbymemberObservable(String key,
String member,
double radius,
GeoUnit unit)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
Observable<JsonArray> |
RedisClient.georadiusbymemberWithOptionsObservable(String key,
String member,
double radius,
GeoUnit unit,
GeoRadiusOptions options)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
Observable<JsonArray> |
RedisClient.georadiusObservable(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
Observable<JsonArray> |
RedisClient.georadiusWithOptionsObservable(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
GeoRadiusOptions options)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
Observable<JsonArray> |
RedisClient.hkeysObservable(String key)
Get all the fields in a hash
|
Observable<JsonArray> |
RedisClient.hmgetObservable(String key,
List<String> fields)
Get the values of all the given hash fields
|
Observable<JsonArray> |
RedisClient.hscanObservable(String key,
String cursor,
ScanOptions options)
Incrementally iterate hash fields and associated values
|
Observable<JsonArray> |
RedisClient.hvalsObservable(String key)
Get all the values in a hash
|
Observable<JsonArray> |
RedisClient.keysObservable(String pattern)
Find all keys matching the given pattern
|
Observable<JsonArray> |
RedisClient.lrangeObservable(String key,
long from,
long to)
Get a range of elements from a list
|
Observable<JsonArray> |
RedisClient.mgetManyObservable(List<String> keys)
Get the values of all the given keys
|
Observable<JsonArray> |
RedisClient.mgetObservable(String key)
Get the value of the given key
|
Observable<JsonArray> |
RedisClient.psubscribeManyObservable(List<String> patterns)
Listen for messages published to channels matching the given patterns
|
Observable<JsonArray> |
RedisClient.psubscribeObservable(String pattern)
Listen for messages published to channels matching the given pattern
|
Observable<JsonArray> |
RedisClient.pubsubChannelsObservable(String pattern)
Lists the currently active channels - only those matching the pattern
|
Observable<JsonArray> |
RedisClient.pubsubNumsubObservable(List<String> channels)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
Observable<JsonArray> |
RedisClient.roleObservable()
Return the role of the instance in the context of replication
|
Observable<JsonArray> |
RedisClient.scanObservable(String cursor,
ScanOptions options)
Incrementally iterate the keys space
|
Observable<JsonArray> |
RedisClient.scriptExistsManyObservable(List<String> scripts)
Check existence of scripts in the script cache.
|
Observable<JsonArray> |
RedisClient.scriptExistsObservable(String script)
Check existence of script in the script cache.
|
Observable<JsonArray> |
RedisClient.sdiffObservable(String key,
List<String> cmpkeys)
Subtract multiple sets
|
Observable<JsonArray> |
RedisClient.sinterObservable(List<String> keys)
Intersect multiple sets
|
Observable<JsonArray> |
RedisClient.slowlogGetObservable(int limit)
Read the Redis slow queries log
|
Observable<JsonArray> |
RedisClient.smembersObservable(String key)
Get all the members in a set
|
Observable<JsonArray> |
RedisClient.sortObservable(String key,
SortOptions options)
Sort the elements in a list, set or sorted set
|
Observable<JsonArray> |
RedisClient.spopManyObservable(String key,
int count)
Remove and return random members from a set
|
Observable<JsonArray> |
RedisClient.srandmemberCountObservable(String key,
int count)
Get one or multiple random members from a set
|
Observable<JsonArray> |
RedisClient.sscanObservable(String key,
String cursor,
ScanOptions options)
Incrementally iterate Set elements
|
Observable<JsonArray> |
RedisClient.subscribeManyObservable(List<String> channels)
Listen for messages published to the given channels
|
Observable<JsonArray> |
RedisClient.subscribeObservable(String channel)
Listen for messages published to the given channels
|
Observable<JsonArray> |
RedisClient.sunionObservable(List<String> keys)
Add multiple sets
|
Observable<JsonArray> |
RedisClient.timeObservable()
Return the current server time
|
Observable<JsonArray> |
RedisClient.zrangebylexObservable(String key,
String min,
String max,
LimitOptions options)
Return a range of members in a sorted set, by lexicographical range
|
Observable<JsonArray> |
RedisClient.zrangebyscoreObservable(String key,
String min,
String max,
RangeLimitOptions options)
Return a range of members in a sorted set, by score
|
Observable<JsonArray> |
RedisClient.zrangeObservable(String key,
long start,
long stop)
Return a range of members in a sorted set, by index
|
Observable<JsonArray> |
RedisClient.zrangeWithOptionsObservable(String key,
long start,
long stop,
RangeOptions options)
Return a range of members in a sorted set, by index
|
Observable<JsonArray> |
RedisClient.zrevrangebylexObservable(String key,
String max,
String min,
LimitOptions options)
Return a range of members in a sorted set, by score, between the given lexicographical range with scores ordered from high to low
|
Observable<JsonArray> |
RedisClient.zrevrangebyscoreObservable(String key,
String max,
String min,
RangeLimitOptions options)
Return a range of members in a sorted set, by score, with scores ordered from high to low
|
Observable<JsonArray> |
RedisClient.zrevrangeObservable(String key,
long start,
long stop,
RangeOptions options)
Return a range of members in a sorted set, by index, with scores ordered from high to low
|
Observable<JsonArray> |
RedisClient.zscanObservable(String key,
String cursor,
ScanOptions options)
Incrementally iterate sorted sets elements and associated scores
|
Modifier and Type | Method and Description |
---|---|
RedisClient |
RedisClient.blpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in a list, or block until one is available
|
RedisClient |
RedisClient.blpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the first element in any of the lists, or block until one is available
|
RedisClient |
RedisClient.brpop(String key,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in a list, or block until one is available
|
RedisClient |
RedisClient.brpopMany(List<String> keys,
int seconds,
Handler<AsyncResult<JsonArray>> handler)
Remove and get the last element in any of the lists, or block until one is available
|
RedisClient |
RedisClient.clusterGetkeysinslot(long slot,
long count,
Handler<AsyncResult<JsonArray>> handler)
Return local key names in the specified hash slot.
|
RedisClient |
RedisClient.clusterInfo(Handler<AsyncResult<JsonArray>> handler)
Provides info about Redis Cluster node state.
|
RedisClient |
RedisClient.clusterNodes(Handler<AsyncResult<JsonArray>> handler)
Get Cluster config for the node.
|
RedisClient |
RedisClient.clusterSlaves(String nodeId,
Handler<AsyncResult<JsonArray>> handler)
List slave nodes of the specified master node.
|
RedisClient |
RedisClient.clusterSlots(Handler<AsyncResult<JsonArray>> handler)
Get array of Cluster slot to node mappings
|
RedisClient |
RedisClient.command(Handler<AsyncResult<JsonArray>> handler)
Get array of Redis command details
|
RedisClient |
RedisClient.commandGetkeys(Handler<AsyncResult<JsonArray>> handler)
Extract keys given a full Redis command
|
RedisClient |
RedisClient.commandInfo(List<String> commands,
Handler<AsyncResult<JsonArray>> handler)
Get array of specific Redis command details
|
RedisClient |
RedisClient.configGet(String parameter,
Handler<AsyncResult<JsonArray>> handler)
Get the value of a configuration parameter
|
RedisClient |
RedisClient.eval(String script,
List<String> keys,
List<String> args,
Handler<AsyncResult<JsonArray>> handler)
Execute a Lua script server side.
|
RedisClient |
RedisClient.evalsha(String sha1,
List<String> keys,
List<String> values,
Handler<AsyncResult<JsonArray>> handler)
Execute a Lua script server side.
|
RedisTransaction |
RedisTransaction.exec(Handler<AsyncResult<JsonArray>> handler)
Execute all commands issued after MULTI
|
RedisClient |
RedisClient.geohash(String key,
String member,
Handler<AsyncResult<JsonArray>> handler)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
RedisClient |
RedisClient.geohashMany(String key,
List<String> members,
Handler<AsyncResult<JsonArray>> handler)
Return valid Geohash strings representing the position of one or more elements in a sorted set value representing
a geospatial index (where elements were added using GEOADD).
|
RedisClient |
RedisClient.geopos(String key,
String member,
Handler<AsyncResult<JsonArray>> handler)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
RedisClient |
RedisClient.geoposMany(String key,
List<String> members,
Handler<AsyncResult<JsonArray>> handler)
Return the positions (longitude,latitude) of all the specified members of the geospatial index represented by the
sorted set at key.
|
RedisClient |
RedisClient.georadius(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
Handler<AsyncResult<JsonArray>> handler)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
RedisClient |
RedisClient.georadiusbymember(String key,
String member,
double radius,
GeoUnit unit,
Handler<AsyncResult<JsonArray>> handler)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
RedisClient |
RedisClient.georadiusbymemberWithOptions(String key,
String member,
double radius,
GeoUnit unit,
GeoRadiusOptions options,
Handler<AsyncResult<JsonArray>> handler)
This command is exactly like GEORADIUS with the sole difference that instead of taking, as the center of the area
to query, a longitude and latitude value, it takes the name of a member already existing inside the geospatial
index represented by the sorted set.
|
RedisClient |
RedisClient.georadiusWithOptions(String key,
double longitude,
double latitude,
double radius,
GeoUnit unit,
GeoRadiusOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return the members of a sorted set populated with geospatial information using GEOADD, which are within the borders
of the area specified with the center location and the maximum distance from the center (the radius).
|
RedisClient |
RedisClient.hkeys(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the fields in a hash
|
RedisClient |
RedisClient.hmget(String key,
List<String> fields,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given hash fields
|
RedisClient |
RedisClient.hscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate hash fields and associated values
|
RedisClient |
RedisClient.hvals(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the values in a hash
|
RedisClient |
RedisClient.keys(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Find all keys matching the given pattern
|
RedisClient |
RedisClient.lrange(String key,
long from,
long to,
Handler<AsyncResult<JsonArray>> handler)
Get a range of elements from a list
|
RedisClient |
RedisClient.mget(String key,
Handler<AsyncResult<JsonArray>> handler)
Get the value of the given key
|
RedisClient |
RedisClient.mgetMany(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Get the values of all the given keys
|
RedisClient |
RedisClient.psubscribe(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to channels matching the given pattern
|
RedisClient |
RedisClient.psubscribeMany(List<String> patterns,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to channels matching the given patterns
|
RedisClient |
RedisClient.pubsubChannels(String pattern,
Handler<AsyncResult<JsonArray>> handler)
Lists the currently active channels - only those matching the pattern
|
RedisClient |
RedisClient.pubsubNumsub(List<String> channels,
Handler<AsyncResult<JsonArray>> handler)
Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels
|
RedisClient |
RedisClient.role(Handler<AsyncResult<JsonArray>> handler)
Return the role of the instance in the context of replication
|
RedisClient |
RedisClient.scan(String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate the keys space
|
RedisClient |
RedisClient.scriptExists(String script,
Handler<AsyncResult<JsonArray>> handler)
Check existence of script in the script cache.
|
RedisClient |
RedisClient.scriptExistsMany(List<String> scripts,
Handler<AsyncResult<JsonArray>> handler)
Check existence of scripts in the script cache.
|
RedisClient |
RedisClient.sdiff(String key,
List<String> cmpkeys,
Handler<AsyncResult<JsonArray>> handler)
Subtract multiple sets
|
RedisClient |
RedisClient.sinter(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Intersect multiple sets
|
RedisClient |
RedisClient.slowlogGet(int limit,
Handler<AsyncResult<JsonArray>> handler)
Read the Redis slow queries log
|
RedisClient |
RedisClient.smembers(String key,
Handler<AsyncResult<JsonArray>> handler)
Get all the members in a set
|
RedisClient |
RedisClient.sort(String key,
SortOptions options,
Handler<AsyncResult<JsonArray>> handler)
Sort the elements in a list, set or sorted set
|
RedisClient |
RedisClient.spopMany(String key,
int count,
Handler<AsyncResult<JsonArray>> handler)
Remove and return random members from a set
|
RedisClient |
RedisClient.srandmemberCount(String key,
int count,
Handler<AsyncResult<JsonArray>> handler)
Get one or multiple random members from a set
|
RedisClient |
RedisClient.sscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate Set elements
|
RedisClient |
RedisClient.subscribe(String channel,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to the given channels
|
RedisClient |
RedisClient.subscribeMany(List<String> channels,
Handler<AsyncResult<JsonArray>> handler)
Listen for messages published to the given channels
|
RedisClient |
RedisClient.sunion(List<String> keys,
Handler<AsyncResult<JsonArray>> handler)
Add multiple sets
|
RedisClient |
RedisClient.time(Handler<AsyncResult<JsonArray>> handler)
Return the current server time
|
RedisClient |
RedisClient.zrange(String key,
long start,
long stop,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
RedisClient.zrangebylex(String key,
String min,
String max,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by lexicographical range
|
RedisClient |
RedisClient.zrangebyscore(String key,
String min,
String max,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score
|
RedisClient |
RedisClient.zrangeWithOptions(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index
|
RedisClient |
RedisClient.zrevrange(String key,
long start,
long stop,
RangeOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by index, with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrangebylex(String key,
String max,
String min,
LimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, between the given lexicographical range with scores ordered from high to low
|
RedisClient |
RedisClient.zrevrangebyscore(String key,
String max,
String min,
RangeLimitOptions options,
Handler<AsyncResult<JsonArray>> handler)
Return a range of members in a sorted set, by score, with scores ordered from high to low
|
RedisClient |
RedisClient.zscan(String key,
String cursor,
ScanOptions options,
Handler<AsyncResult<JsonArray>> handler)
Incrementally iterate sorted sets elements and associated scores
|
Copyright © 2016. All rights reserved.