public class RedisSortedSetMethods
extends io.toro.martini.redis.RedisBaseMethods
Constructor and Description |
---|
RedisSortedSetMethods(DataSourceManager dataSourceManager) |
Modifier and Type | Method and Description |
---|---|
static GloopModel |
bzpopmax(String connectionName,
long timeout,
GloopExecutionContext context,
Object... keys)
Removes and returns a member with the highest scores in the sorted set stored at one of the keys.
|
static Future<KeyValue<Object,ScoredValue<Object>>> |
bzpopmaxAsync(String connectionName,
long timeout,
GloopExecutionContext context,
Object... keys)
Asynchronously removes and returns a member with the highest scores in the sorted set stored at one of the keys.
|
static GloopModel |
bzpopmin(String connectionName,
long timeout,
GloopExecutionContext context,
Object... keys)
Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
|
static Future<KeyValue<Object,ScoredValue<Object>>> |
bzpopminAsync(String connectionName,
long timeout,
GloopExecutionContext context,
Object... keys)
Asynchronously removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
|
static Long |
zadd(String connectionName,
Object key,
double score,
Object member,
GloopExecutionContext context)
Add one or more members to a sorted set, or update its score if it already exists.
|
static Long |
zadd(String connectionName,
Object key,
GloopExecutionContext context,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
static Long |
zadd(String connectionName,
Object key,
GloopExecutionContext context,
ScoredValue<Object>... scoredValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
static Long |
zadd(String connectionName,
Object key,
ZAddArgs zaddArgs,
double score,
Object member,
GloopExecutionContext context)
Add one or more members to a sorted set, or update its score if it already exists.
|
static Long |
zadd(String connectionName,
Object key,
ZAddArgs zaddArgs,
GloopExecutionContext context,
Object... scoresAndValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
static Long |
zadd(String connectionName,
Object key,
ZAddArgs zaddArgs,
GloopExecutionContext context,
ScoredValue<Object>... scoredValues)
Add one or more members to a sorted set, or update its score if it already exists.
|
static Future<Long> |
zaddAsync(String connectionName,
Object key,
double score,
Object member,
GloopExecutionContext context)
Asynchronously add one or more members to a sorted set, or update its score if it already exists.
|
static Future<Long> |
zaddAsync(String connectionName,
Object key,
GloopExecutionContext context,
Object... scoresAndValues)
Asynchronously add one or more members to a sorted set, or update its score if it already exists.
|
static Future<Long> |
zaddAsync(String connectionName,
Object key,
GloopExecutionContext context,
ScoredValue<Object>... scoredValues)
Asynchronously add one or more members to a sorted set, or update its score if it already exists.
|
static Future<Long> |
zaddAsync(String connectionName,
Object key,
ZAddArgs zaddArgs,
double score,
Object member,
GloopExecutionContext context)
Asynchronously add one or more members to a sorted set, or update its score if it already exists.
|
static Future<Long> |
zaddAsync(String connectionName,
Object key,
ZAddArgs zaddArgs,
GloopExecutionContext context,
Object... scoresAndValues)
Asynchronously add one or more members to a sorted set, or update its score if it already exists.
|
static Future<Long> |
zaddAsync(String connectionName,
Object key,
ZAddArgs zaddArgs,
GloopExecutionContext context,
ScoredValue<Object>... scoredValues)
Asynchronously add one or more members to a sorted set, or update its score if it already exists.
|
static Double |
zaddincr(String connectionName,
Object key,
double score,
Object member,
GloopExecutionContext context)
Add one or more members to a sorted set, or update its score if it already exists applying the
INCR
option. |
static Double |
zaddincr(String connectionName,
Object key,
ZAddArgs zaddArgs,
double score,
Object member,
GloopExecutionContext context)
Add one or more members to a sorted set, or update its score if it already exists applying the
INCR
option. |
static Future<Double> |
zaddincrAsync(String connectionName,
Object key,
double score,
Object member,
GloopExecutionContext context)
Asynchronously add one or more members to a sorted set, or update its score if it already exists applying the
iNCR option. |
static Future<Double> |
zaddincrAsync(String connectionName,
Object key,
ZAddArgs zaddArgs,
double score,
Object member,
GloopExecutionContext context)
Asynchronously add one or more members to a sorted set, or update its score if it already exists applying the
iNCR option. |
static Long |
zcard(String connectionName,
Object key,
GloopExecutionContext context)
Get the number of members in a sorted set.
|
static Future<Long> |
zcardAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously get the number of members in a sorted set.
|
static Long |
zcount(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Count the members in a sorted set with scores within the given
Range . |
static Future<Long> |
zcountAsync(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously count the members in a sorted set with scores within the given
Range . |
static Double |
zincrby(String connectionName,
Object key,
double amount,
Object member,
GloopExecutionContext context)
Increment the score of a member in a sorted set.
|
static Future<Double> |
zincrbyAsync(String connectionName,
Object key,
double amount,
Object member,
GloopExecutionContext context)
Asynchronously increment the score of a member in a sorted set.
|
static Long |
zinterstore(String connectionName,
Object destination,
GloopExecutionContext context,
Object... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
static Long |
zinterstore(String connectionName,
Object destination,
ZStoreArgs storeArgs,
GloopExecutionContext context,
Object... keys)
Intersect multiple sorted sets and store the resulting sorted set in a new key.
|
static Future<Long> |
zinterstoreAsync(String connectionName,
Object destination,
GloopExecutionContext context,
Object... keys)
Asynchronously intersect multiple sorted sets and store the resulting sorted set in a new key.
|
static Future<Long> |
zinterstoreAsync(String connectionName,
Object destination,
ZStoreArgs storeArgs,
GloopExecutionContext context,
Object... keys)
Asynchronously intersect multiple sorted sets and store the resulting sorted set in a new key.
|
static Long |
zlexcount(String connectionName,
Object key,
Range<Object> range,
GloopExecutionContext context)
Count the number of members in a sorted set between a given lexicographical range.
|
static Future<Long> |
zlexcountAsync(String connectionName,
Object key,
Range<Object> range,
GloopExecutionContext context)
Asynchronously count the number of members in a sorted set between a given lexicographical range.
|
static ScoredValue<Object> |
zpopmax(String connectionName,
Object key,
GloopExecutionContext context)
Removes and returns up to count members with the highest scores in the sorted set stored at key.
|
static List<ScoredValue<Object>> |
zpopmax(String connectionName,
Object key,
long count,
GloopExecutionContext context)
Removes and returns up to count members with the highest scores in the sorted set stored at key.
|
static Future<ScoredValue<Object>> |
zpopmaxAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously removes and returns up to count members with the highest scores in the sorted set stored at key.
|
static Future<List<ScoredValue<Object>>> |
zpopmaxAsync(String connectionName,
Object key,
long count,
GloopExecutionContext context)
Asynchronously removes and returns up to count members with the highest scores in the sorted set stored at key.
|
static ScoredValue<Object> |
zpopmin(String connectionName,
Object key,
GloopExecutionContext context)
Removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
static List<ScoredValue<Object>> |
zpopmin(String connectionName,
Object key,
long count,
GloopExecutionContext context)
Removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
static Future<ScoredValue<Object>> |
zpopminAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
static Future<List<ScoredValue<Object>>> |
zpopminAsync(String connectionName,
Object key,
long count,
GloopExecutionContext context)
Asynchronously removes and returns up to count members with the lowest scores in the sorted set stored at key.
|
static List<Object> |
zrange(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Return a range of members in a sorted set, by index.
|
static Long |
zrange(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
long start,
long stop,
GloopExecutionContext context)
Return a range of members in a sorted set, by index.
|
static Future<List<Object>> |
zrangeAsync(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by index.
|
static Future<Long> |
zrangeAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by index.
|
static List<Object> |
zrangebylex(String connectionName,
Object key,
Range<Object> range,
GloopExecutionContext context)
Return a range of members in a sorted set, by lexicographical range.
|
static List<Object> |
zrangebylex(String connectionName,
Object key,
Range<Object> range,
Limit limit,
GloopExecutionContext context)
Return a range of members in a sorted set, by lexicographical range.
|
static Future<List<Object>> |
zrangebylexAsync(String connectionName,
Object key,
Range<Object> range,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by lexicographical range.
|
static Future<List<Object>> |
zrangebylexAsync(String connectionName,
Object key,
Range<Object> range,
Limit limit,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by lexicographical range.
|
static List<Object> |
zrangebyscore(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Return a range of members in a sorted set, by score.
|
static List<Object> |
zrangebyscore(String connectionName,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Return a range of members in a sorted set, by score.
|
static Long |
zrangebyscore(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Stream over a range of members in a sorted set, by score.
|
static Long |
zrangebyscore(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Stream over a range of members in a sorted set, by score.
|
static Future<List<Object>> |
zrangebyscoreAsync(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by score.
|
static Future<List<Object>> |
zrangebyscoreAsync(String connectionName,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by score.
|
static Future<Long> |
zrangebyscoreAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously stream over a range of members in a sorted set, by score.
|
static Future<Long> |
zrangebyscoreAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Asynchronously stream over a range of members in a sorted set, by score.
|
static List<ScoredValue<Object>> |
zrangebyscoreWithScores(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Return a range of members with score in a sorted set, by score.
|
static List<ScoredValue<Object>> |
zrangebyscoreWithScores(String connectionName,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Return a range of members with score in a sorted set, by score.
|
static Long |
zrangebyscoreWithScores(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Stream over a range of members with scores in a sorted set, by score.
|
static Long |
zrangebyscoreWithScores(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Stream over a range of members with scores in a sorted set, by score.
|
static Future<List<ScoredValue<Object>>> |
zrangebyscoreWithScoresAsync(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously return a range of members with score in a sorted set, by score.
|
static Future<List<ScoredValue<Object>>> |
zrangebyscoreWithScoresAsync(String connectionName,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Asynchronously return a range of members with score in a sorted set, by score.
|
static Future<Long> |
zrangebyscoreWithScoresAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously stream over a range of members with scores in a sorted set, by score.
|
static Future<Long> |
zrangebyscoreWithScoresAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Asynchronously stream over a range of members with scores in a sorted set, by score.
|
static List<ScoredValue<Object>> |
zrangeWithScores(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Return a range of members with scores in a sorted set, by index.
|
static Long |
zrangeWithScores(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
long start,
long stop,
GloopExecutionContext context)
Stream over a range of members with scores in a sorted set, by index.
|
static Future<List<ScoredValue<Object>>> |
zrangeWithScoresAsync(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously return a range of members with scores in a sorted set, by index.
|
static Future<Long> |
zrangeWithScoresAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously stream over a range of members with scores in a sorted set, by index.
|
static Long |
zrank(String connectionName,
Object key,
Object member,
GloopExecutionContext context)
Determine the index of a member in a sorted set.
|
static Future<Long> |
zrankAsync(String connectionName,
Object key,
Object member,
GloopExecutionContext context)
Asynchronously determine the index of a member in a sorted set.
|
static Long |
zrem(String connectionName,
Object key,
GloopExecutionContext context,
Object... members)
Remove one or more members from a sorted set.
|
static Future<Long> |
zremAsync(String connectionName,
Object key,
GloopExecutionContext context,
Object... members)
Asynchronously remove one or more members from a sorted set.
|
static Long |
zremrangebylex(String connectionName,
Object key,
Range<Object> range,
GloopExecutionContext context)
Remove all members in a sorted set between the given lexicographical range.
|
static Future<Long> |
zremrangebylexAsync(String connectionName,
Object key,
Range<Object> range,
GloopExecutionContext context)
Asynchronously remove all members in a sorted set between the given lexicographical range.
|
static Long |
zremrangebyrank(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Remove all members in a sorted set within the given indexes.
|
static Future<Long> |
zremrangebyrankAsync(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously remove all members in a sorted set within the given indexes.
|
static Long |
zremrangebyscore(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Remove all members in a sorted set within the given scores.
|
static Future<Long> |
zremrangebyscoreAsync(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously remove all members in a sorted set within the given scores.
|
static List<Object> |
zrevrange(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Return a range of members in a sorted set, by index, with scores ordered from high to low.
|
static Long |
zrevrange(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
long start,
long stop,
GloopExecutionContext context)
Stream over a range of members in a sorted set, by index, with scores ordered from high to low.
|
static Future<List<Object>> |
zrevrangeAsync(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by index, with scores ordered from high to low.
|
static Future<Long> |
zrevrangeAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously stream over a range of members in a sorted set, by index, with scores ordered from high to low.
|
static List<Object> |
zrevrangebylex(String connectionName,
Object key,
Range<Object> range,
GloopExecutionContext context)
Return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
static List<Object> |
zrevrangebylex(String connectionName,
Object key,
Range<Object> range,
Limit limit,
GloopExecutionContext context)
Return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
static Future<List<Object>> |
zrevrangebylexAsync(String connectionName,
Object key,
Range<Object> range,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
static Future<List<Object>> |
zrevrangebylexAsync(String connectionName,
Object key,
Range<Object> range,
Limit limit,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by lexicographical range ordered from high to low.
|
static List<Object> |
zrevrangebyscore(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
static List<Object> |
zrevrangebyscore(String connectionName,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Return a range of members in a sorted set, by score, with scores ordered from high to low.
|
static Long |
zrevrangebyscore(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
static Long |
zrevrangebyscore(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
static Future<List<Object>> |
zrevrangebyscoreAsync(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by score, with scores ordered from high to low.
|
static Future<List<Object>> |
zrevrangebyscoreAsync(String connectionName,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Asynchronously return a range of members in a sorted set, by score, with scores ordered from high to low.
|
static Future<Long> |
zrevrangebyscoreAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
static Future<Long> |
zrevrangebyscoreAsync(String connectionName,
ValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Asynchronously stream over a range of members in a sorted set, by score, with scores ordered from high to low.
|
static List<ScoredValue<Object>> |
zrevrangebyscoreWithScores(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
static List<ScoredValue<Object>> |
zrevrangebyscoreWithScores(String connectionName,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
static Long |
zrevrangebyscoreWithScores(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
static Long |
zrevrangebyscoreWithScores(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
|
static Future<List<ScoredValue<Object>>> |
zrevrangebyscoreWithScoresAsync(String connectionName,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously return a range of members with scores in a sorted set, by score, with scores ordered from high to
low.
|
static Future<List<ScoredValue<Object>>> |
zrevrangebyscoreWithScoresAsync(String connectionName,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Asynchronously return a range of members with scores in a sorted set, by score, with scores ordered from high to
low.
|
static Future<Long> |
zrevrangebyscoreWithScoresAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
GloopExecutionContext context)
Asynchronously stream over a range of members with scores in a sorted set, by score, with scores ordered from
high to low.
|
static Future<Long> |
zrevrangebyscoreWithScoresAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
Range<? extends Number> range,
Limit limit,
GloopExecutionContext context)
Asynchronously stream over a range of members with scores in a sorted set, by score, with scores ordered from
high to low.
|
static List<ScoredValue<Object>> |
zrevrangeWithScores(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Return a range of members with scores in a sorted set, by index, with scores ordered from high to low.
|
static Long |
zrevrangeWithScores(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
long start,
long stop,
GloopExecutionContext context)
Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.
|
static Future<List<ScoredValue<Object>>> |
zrevrangeWithScoresAsync(String connectionName,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously return a range of members with scores in a sorted set, by index, with scores ordered from high to
low.
|
static Future<Long> |
zrevrangeWithScoresAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
long start,
long stop,
GloopExecutionContext context)
Asynchronously stream over a range of members with scores in a sorted set, by index, with scores ordered from
high to low.
|
static Long |
zrevrank(String connectionName,
Object key,
Object member,
GloopExecutionContext context)
Determine the index of a member in a sorted set, with scores ordered from high to low.
|
static Future<Long> |
zrevrankAsync(String connectionName,
Object key,
Object member,
GloopExecutionContext context)
Asynchronously determine the index of a member in a sorted set, with scores ordered from high to low.
|
static ScoredValueScanCursor<Object> |
zscan(String connectionName,
Object key,
GloopExecutionContext context)
Incrementally iterate sorted sets elements and associated scores.
|
static ScoredValueScanCursor<Object> |
zscan(String connectionName,
Object key,
ScanArgs scanArgs,
GloopExecutionContext context)
Incrementally iterate sorted sets elements and associated scores.
|
static ScoredValueScanCursor<Object> |
zscan(String connectionName,
Object key,
ScanCursor scanCursor,
GloopExecutionContext context)
Incrementally iterate sorted sets elements and associated scores.
|
static ScoredValueScanCursor<Object> |
zscan(String connectionName,
Object key,
ScanCursor scanCursor,
ScanArgs scanArgs,
GloopExecutionContext context)
Incrementally iterate sorted sets elements and associated scores.
|
static StreamScanCursor |
zscan(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
GloopExecutionContext context)
Incrementally iterate sorted sets elements and associated scores.
|
static StreamScanCursor |
zscan(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
ScanArgs scanArgs,
GloopExecutionContext context)
Incrementally iterate sorted sets elements and associated scores.
|
static StreamScanCursor |
zscan(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
ScanCursor scanCursor,
GloopExecutionContext context)
Incrementally iterate sorted sets elements and associated scores.
|
static StreamScanCursor |
zscan(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
ScanCursor scanCursor,
ScanArgs scanArgs,
GloopExecutionContext context)
Incrementally iterate sorted sets elements and associated scores.
|
static Future<ScoredValueScanCursor<Object>> |
zscanAsync(String connectionName,
Object key,
GloopExecutionContext context)
Asynchronously incrementally iterate sorted sets elements and associated scores.
|
static Future<ScoredValueScanCursor<Object>> |
zscanAsync(String connectionName,
Object key,
ScanArgs scanArgs,
GloopExecutionContext context)
Asynchronously incrementally iterate sorted sets elements and associated scores.
|
static Future<ScoredValueScanCursor<Object>> |
zscanAsync(String connectionName,
Object key,
ScanCursor scanCursor,
GloopExecutionContext context)
Asynchronously incrementally iterate sorted sets elements and associated scores.
|
static Future<ScoredValueScanCursor<Object>> |
zscanAsync(String connectionName,
Object key,
ScanCursor scanCursor,
ScanArgs scanArgs,
GloopExecutionContext context)
Asynchronously incrementally iterate sorted sets elements and associated scores.
|
static Future<StreamScanCursor> |
zscanAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
GloopExecutionContext context)
Asynchronously incrementally iterate sorted sets elements and associated scores.
|
static Future<StreamScanCursor> |
zscanAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
ScanArgs scanArgs,
GloopExecutionContext context)
Asynchronously incrementally iterate sorted sets elements and associated scores.
|
static Future<StreamScanCursor> |
zscanAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
ScanCursor scanCursor,
GloopExecutionContext context)
Asynchronously incrementally iterate sorted sets elements and associated scores.
|
static Future<StreamScanCursor> |
zscanAsync(String connectionName,
ScoredValueStreamingChannel<Object> channel,
Object key,
ScanCursor scanCursor,
ScanArgs scanArgs,
GloopExecutionContext context)
Asynchronously incrementally iterate sorted sets elements and associated scores.
|
static Double |
zscore(String connectionName,
Object key,
Object member,
GloopExecutionContext context)
Get the score associated with the given member in a sorted set.
|
static Future<Double> |
zscoreAsync(String connectionName,
Object key,
Object member,
GloopExecutionContext context)
Asynchronously get the score associated with the given member in a sorted set.
|
static Long |
zunionstore(String connectionName,
Object destination,
GloopExecutionContext context,
Object... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
static Long |
zunionstore(String connectionName,
Object destination,
ZStoreArgs storeArgs,
GloopExecutionContext context,
Object... keys)
Add multiple sorted sets and store the resulting sorted set in a new key.
|
static Future<Long> |
zunionstoreAsync(String connectionName,
Object destination,
GloopExecutionContext context,
Object... keys)
Asynchronously add multiple sorted sets and store the resulting sorted set in a new key.
|
static Future<Long> |
zunionstoreAsync(String connectionName,
Object destination,
ZStoreArgs storeArgs,
GloopExecutionContext context,
Object... keys)
Asynchronously add multiple sorted sets and store the resulting sorted set in a new key.
|
@Autowired RedisSortedSetMethods(DataSourceManager dataSourceManager)
@GloopObjectParameter(value="output{\n redisKeyValue{\n key:object\n value:object\n }\n}") public static GloopModel bzpopmin(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) long timeout, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool nametimeout
- the timeout in seconds.keys
- the keys.@GloopParameter(name="redisFutureBzpopminOutput") public static Future<KeyValue<Object,ScoredValue<Object>>> bzpopminAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) long timeout, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool nametimeout
- the timeout in seconds.keys
- the keys.@GloopObjectParameter(value="output{\n redisKeyValue{\n key:object\n value:object\n }\n}") public static GloopModel bzpopmax(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) long timeout, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool nametimeout
- the timeout in seconds.keys
- the keys.@GloopParameter(name="redisFutureBzpopmaxOutput") public static Future<KeyValue<Object,ScoredValue<Object>>> bzpopmaxAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) long timeout, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool nametimeout
- the timeout in seconds.keys
- the keys.@GloopParameter(name="redisZaddOutput") public static Long zadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) double score, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscore
- the scoremember
- the member@GloopParameter(name="redisZaddOutput") public static Long zadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... scoresAndValues)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscoresAndValues
- the scoresAndValue tuples (score,value,score,value,...)@GloopParameter(name="redisZaddOutput") public static Long zadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context, @GloopParameter(allowNull=false) ScoredValue<Object>... scoredValues)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscoredValues
- the scored values@GloopParameter(name="redisZaddOutput") public static Long zadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ZAddArgs zaddArgs, @GloopParameter(allowNull=false) double score, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyzaddArgs
- arguments for zaddscore
- the scoremember
- the member@GloopParameter(name="redisZaddOutput") public static Long zadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ZAddArgs zaddArgs, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... scoresAndValues)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyzaddArgs
- arguments for zaddscoresAndValues
- the scoresAndValue tuples (score,value,score,value,...)@GloopParameter(name="redisZaddOutput") public static Long zadd(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ZAddArgs zaddArgs, GloopExecutionContext context, @GloopParameter(allowNull=false) ScoredValue<Object>... scoredValues)
connectionName
- The Martini Runtime Redis connection pool namekey
- the kezaddArgs
- arguments for zaddscoredValues
- the scored values@GloopParameter(name="redisFutureZaddOutput") public static Future<Long> zaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) double score, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscore
- the scoremember
- the member@GloopParameter(name="redisFutureZaddOutput") public static Future<Long> zaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... scoresAndValues)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscoresAndValues
- the scoresAndValue tuples (score,value,score,value,...)@GloopParameter(name="redisFutureZaddOutput") public static Future<Long> zaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context, @GloopParameter(allowNull=false) ScoredValue<Object>... scoredValues)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscoredValues
- the scored values@GloopParameter(name="redisFutureZaddOutput") public static Future<Long> zaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ZAddArgs zaddArgs, @GloopParameter(allowNull=false) double score, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyzaddArgs
- arguments for zaddscore
- the scoremember
- the member@GloopParameter(name="redisFutureZaddOutput") public static Future<Long> zaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ZAddArgs zaddArgs, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... scoresAndValues)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyzaddArgs
- arguments for zaddscoresAndValues
- the scoresAndValue tuples (score,value,score,value,...)@GloopParameter(name="redisFutureZaddOutput") public static Future<Long> zaddAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ZAddArgs zaddArgs, GloopExecutionContext context, @GloopParameter(allowNull=false) ScoredValue<Object>... scoredValues)
connectionName
- The Martini Runtime Redis connection pool namekey
- the kezaddArgs
- arguments for zaddscoredValues
- the scored values@GloopParameter(name="redisZaddincrOutput") public static Double zaddincr(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) double score, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
INCR
option. ZADD acts like ZINCRBY.connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscore
- the scoremember
- the member@GloopParameter(name="redisZaddincrOutput") public static Double zaddincr(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ZAddArgs zaddArgs, @GloopParameter(allowNull=false) double score, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
INCR
option. ZADD acts like ZINCRBY.connectionName
- The Martini Runtime Redis connection pool namekey
- the keyzaddArgs
- arguments for zaddscore
- the scoremember
- the member@GloopParameter(name="redisFutureZaddincrOutput") public static Future<Double> zaddincrAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) double score, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
iNCR
option. zADD acts like zINCRBY.connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscore
- the scoremember
- the member@GloopParameter(name="redisFutureZaddincrOutput") public static Future<Double> zaddincrAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ZAddArgs zaddArgs, @GloopParameter(allowNull=false) double score, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
iNCR
option. zADD acts like zINCRBY.connectionName
- The Martini Runtime Redis connection pool namekey
- the keyzaddArgs
- arguments for zaddscore
- the scoremember
- the member@GloopParameter(name="redisZcardOutput") public static Long zcard(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist.@GloopParameter(name="redisFutureZcardOutput") public static Future<Long> zcardAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keykey
does not exist.@GloopParameter(name="redisZcountOutput") public static Long zcount(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
Range
.connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZcountOutput") public static Future<Long> zcountAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
Range
.connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZincrbyOutput") public static Double zincrby(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) double amount, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyamount
- the increment type: longmember
- the member type: valuemember
(a double precision floating point number),
represented as string.@GloopParameter(name="redisFutureZincrbyOutput") public static Future<Double> zincrbyAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) double amount, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyamount
- the increment type: longmember
- the member type: valuemember
(a double precision floating point number),
represented as string.@GloopParameter(name="redisZinterstoreOutput") public static Long zinterstore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destinationkeys
- the keysdestination
.@GloopParameter(name="redisZinterstoreOutput") public static Long zinterstore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, @GloopParameter(allowNull=false) ZStoreArgs storeArgs, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destinationstoreArgs
- the storeArgskeys
- the keysdestination
.@GloopParameter(name="redisFutureZinterstoreOutput") public static Future<Long> zinterstoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destinationkeys
- the keysdestination
.@GloopParameter(name="redisFutureZinterstoreOutput") public static Future<Long> zinterstoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, @GloopParameter(allowNull=false) ZStoreArgs storeArgs, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destinationstoreArgs
- the storeArgskeys
- the keysdestination
.@GloopParameter(name="redisZlexcountOutput") public static Long zlexcount(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZlexcountOutput") public static Future<Long> zlexcountAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZpopminOutput") public static ScoredValue<Object> zpopmin(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisZpopminOutput") public static List<ScoredValue<Object>> zpopmin(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key.count
- the number of elements to return.@GloopParameter(name="redisFutureZpopminOutput") public static Future<ScoredValue<Object>> zpopminAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureZpopminOutput") public static Future<List<ScoredValue<Object>>> zpopminAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key.count
- the number of elements to return.@GloopParameter(name="redisZpopmaxOutput") public static ScoredValue<Object> zpopmax(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisZpopmaxOutput") public static List<ScoredValue<Object>> zpopmax(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key.count
- the number of elements to return.@GloopParameter(name="redisFutureZpopmaxOutput") public static Future<ScoredValue<Object>> zpopmaxAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureZpopmaxOutput") public static Future<List<ScoredValue<Object>>> zpopmaxAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long count, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key.count
- the number of elements to return.@GloopParameter(name="redisZrangeOutput") public static Long zrange(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisZrangeOutput") public static List<Object> zrange(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisFutureZrangeOutput") public static Future<List<Object>> zrangeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisFutureZrangeOutput") public static Future<Long> zrangeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisZrangeWithScoresOutput") public static List<ScoredValue<Object>> zrangeWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisZrangeWithScoresOutput") public static Long zrangeWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisFutureZrangeWithScoresOutput") public static Future<List<ScoredValue<Object>>> zrangeWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisFutureZrangeWithScoresOutput") public static Future<Long> zrangeWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisZrangebylexOutput") public static List<Object> zrangebylex(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZrangebylexOutput") public static List<Object> zrangebylex(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrangebylexOutput") public static Future<List<Object>> zrangebylexAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrangebylexOutput") public static Future<List<Object>> zrangebylexAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrangebyscoreOutput") public static List<Object> zrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZrangebyscoreOutput") public static List<Object> zrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrangebyscoreOutput") public static Long zrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyrange
- the range@GloopParameter(name="redisZrangebyscoreOutput") public static Long zrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrangebyscoreOutput") public static Future<List<Object>> zrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrangebyscoreOutput") public static Future<List<Object>> zrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrangebyscoreOutput") public static Future<Long> zrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrangebyscoreOutput") public static Future<Long> zrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrangebyscoreWithScoresOutput") public static List<ScoredValue<Object>> zrangebyscoreWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZrangebyscoreWithScoresOutput") public static List<ScoredValue<Object>> zrangebyscoreWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrangebyscoreWithScoresOutput") public static Long zrangebyscoreWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyrange
- the range@GloopParameter(name="redisZrangebyscoreWithScoresOutput") public static Long zrangebyscoreWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrangebyscoreWithScoresOutput") public static Future<List<ScoredValue<Object>>> zrangebyscoreWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrangebyscoreWithScoresOutput") public static Future<List<ScoredValue<Object>>> zrangebyscoreWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrangebyscoreWithScoresOutput") public static Future<Long> zrangebyscoreWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrangebyscoreWithScoresOutput") public static Future<Long> zrangebyscoreWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrankOutput") public static Long zrank(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymember
- the member type: valuemember
. If member
does not exist in the sorted set or
key
does not exist,@GloopParameter(name="redisFutureZrankOutput") public static Future<Long> zrankAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymember
- the member type: valuemember
. if member
does not exist in the sorted set or
key
does not exist,@GloopParameter(name="redisZremOutput") public static Long zrem(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... members)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymembers
- the member type: value@GloopParameter(name="redisFutureZremOutput") public static Future<Long> zremAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... members)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymembers
- the member type: value@GloopParameter(name="redisZremrangebylexOutput") public static Long zremrangebylex(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZremrangebylexOutput") public static Future<Long> zremrangebylexAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZremrangebyrankOutput") public static Long zremrangebyrank(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the start type: longstop
- the stop type: long@GloopParameter(name="redisZremrangebyscoreOutput") public static Long zremrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZremrangebyrankOutput") public static Future<Long> zremrangebyrankAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the start type: longstop
- the stop type: long@GloopParameter(name="redisFutureZremrangebyscoreOutput") public static Future<Long> zremrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZrevrangeOutput") public static List<Object> zrevrange(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisZrevrangeOutput") public static Long zrevrange(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisFutureZrevrangeOutput") public static Future<List<Object>> zrevrangeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisFutureZrevrangeOutput") public static Future<Long> zrevrangeAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisZrevrangeWithScoresOutput") public static List<ScoredValue<Object>> zrevrangeWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisZrevrangeWithScoresOutput") public static Long zrevrangeWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisFutureZrevrangeWithScoresOutput") public static Future<List<ScoredValue<Object>>> zrevrangeWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisFutureZrevrangeWithScoresOutput") public static Future<Long> zrevrangeWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) long start, @GloopParameter(allowNull=false) long stop, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keystart
- the startstop
- the stop@GloopParameter(name="redisZrevrangebylexOutput") public static List<Object> zrevrangebylex(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZrevrangebylexOutput") public static List<Object> zrevrangebylex(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrevrangebylexOutput") public static Future<List<Object>> zrevrangebylexAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrevrangebylexOutput") public static Future<List<Object>> zrevrangebylexAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<Object> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrevrangebyscoreOutput") public static List<Object> zrevrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZrevrangebyscoreOutput") public static List<Object> zrevrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrevrangebyscoreOutput") public static Long zrevrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyrange
- the range@GloopParameter(name="redisZrevrangebyscoreOutput") public static Long zrevrangebyscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrevrangebyscoreOutput") public static Future<List<Object>> zrevrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrevrangebyscoreOutput") public static Future<List<Object>> zrevrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrevrangebyscoreOutput") public static Future<Long> zrevrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrevrangebyscoreOutput") public static Future<Long> zrevrangebyscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every valuekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrevrangebyscoreWithScoresOutput") public static List<ScoredValue<Object>> zrevrangebyscoreWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisZrevrangebyscoreWithScoresOutput") public static List<ScoredValue<Object>> zrevrangebyscoreWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- limit@GloopParameter(name="redisZrevrangebyscoreWithScoresOutput") public static Long zrevrangebyscoreWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyrange
- the range@GloopParameter(name="redisZrevrangebyscoreWithScoresOutput") public static Long zrevrangebyscoreWithScores(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisFutureZrevrangebyscoreWithScoresOutput") public static Future<List<ScoredValue<Object>>> zrevrangebyscoreWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrevrangebyscoreWithScoresOutput") public static Future<List<ScoredValue<Object>>> zrevrangebyscoreWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyrange
- the rangelimit
- limit@GloopParameter(name="redisFutureZrevrangebyscoreWithScoresOutput") public static Future<Long> zrevrangebyscoreWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyrange
- the range@GloopParameter(name="redisFutureZrevrangebyscoreWithScoresOutput") public static Future<Long> zrevrangebyscoreWithScoresAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Range<? extends Number> range, @GloopParameter(allowNull=false) Limit limit, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyrange
- the rangelimit
- the limit@GloopParameter(name="redisZrevrankOutput") public static Long zrevrank(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymember
- the member type: valuemember
. If member
does not exist in the sorted set or
key
does not exist,@GloopParameter(name="redisFutureZrevrankOutput") public static Future<Long> zrevrankAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymember
- the member type: valuemember
. if member
does not exist in the sorted set or
key
does not exist,@GloopParameter(name="redisZscanOutput") public static ScoredValueScanCursor<Object> zscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisZscanOutput") public static ScoredValueScanCursor<Object> zscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanArgs scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisZscanOutput") public static ScoredValueScanCursor<Object> zscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, @GloopParameter(allowNull=false) ScanArgs scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisZscanOutput") public static ScoredValueScanCursor<Object> zscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisZscanOutput") public static StreamScanCursor zscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the key@GloopParameter(name="redisZscanOutput") public static StreamScanCursor zscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanArgs scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisZscanOutput") public static StreamScanCursor zscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, @GloopParameter(allowNull=false) ScanArgs scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisZscanOutput") public static StreamScanCursor zscan(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisFutureZscanOutput") public static Future<ScoredValueScanCursor<Object>> zscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the key@GloopParameter(name="redisFutureZscanOutput") public static Future<ScoredValueScanCursor<Object>> zscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanArgs scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisFutureZscanOutput") public static Future<ScoredValueScanCursor<Object>> zscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, @GloopParameter(allowNull=false) ScanArgs scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisFutureZscanOutput") public static Future<ScoredValueScanCursor<Object>> zscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisFutureZscanOutput") public static Future<StreamScanCursor> zscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the key@GloopParameter(name="redisFutureZscanOutput") public static Future<StreamScanCursor> zscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanArgs scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyscanArgs
- scan arguments@GloopParameter(name="redisFutureZscanOutput") public static Future<StreamScanCursor> zscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, @GloopParameter(allowNull=false) ScanArgs scanArgs, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be nullscanArgs
- scan arguments@GloopParameter(name="redisFutureZscanOutput") public static Future<StreamScanCursor> zscanAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) ScoredValueStreamingChannel<Object> channel, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) ScanCursor scanCursor, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namechannel
- streaming channel that receives a call for every scored valuekey
- the keyscanCursor
- cursor to resume from a previous scan, must not be null@GloopParameter(name="redisZscoreOutput") public static Double zscore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymember
- the member type: valuemember
(a double precision floating point number),
represented as string.@GloopParameter(name="redisFutureZscoreOutput") public static Future<Double> zscoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object key, @GloopParameter(allowNull=false) Object member, GloopExecutionContext context)
connectionName
- The Martini Runtime Redis connection pool namekey
- the keymember
- the member type: valuemember
(a double precision floating point number),
represented as string.@GloopParameter(name="redisZunionstoreOutput") public static Long zunionstore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- destination keykeys
- source keysdestination
.@GloopParameter(name="redisZunionstoreOutput") public static Long zunionstore(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, @GloopParameter(allowNull=false) ZStoreArgs storeArgs, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destinationstoreArgs
- the storeArgskeys
- the keysdestination
.@GloopParameter(name="redisFutureZunionstoreOutput") public static Future<Long> zunionstoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- destination keykeys
- source keysdestination
.@GloopParameter(name="redisFutureZunionstoreOutput") public static Future<Long> zunionstoreAsync(@GloopParameter(allowNull=false) String connectionName, @GloopParameter(allowNull=false) Object destination, @GloopParameter(allowNull=false) ZStoreArgs storeArgs, GloopExecutionContext context, @GloopParameter(allowNull=false) Object... keys)
connectionName
- The Martini Runtime Redis connection pool namedestination
- the destinationstoreArgs
- the storeArgskeys
- the keysdestination
.Copyright © 2023. All rights reserved.